百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 文章教程 > 正文

时间轮的艺术:原理、使用场景及复杂业务环境下的Java实践

yund56 2025-05-02 20:54 26 浏览

一、什么是时间轮

时间轮(Timing Wheel)是一种数据结构,用于管理需要在未来某个时间点被执行的定时任务。其核心思想源于时钟:一个圆形的时间轮有多个槽,每个槽代表一个时间间隔。时间轮有一个指针按固定频率轮询每个槽,当指针到达某个槽时,就会执行该槽中的所有任务。

时间轮是用来处理大量定时任务的一种高效方法。这种数据结构特别适用于处理那些可以容忍一些时间误差的任务,例如网络连接超时检查、缓存项目的过期等。

二、时间轮的使用场景

  1. 超时处理:例如网络协议中的超时重传、服务器中的会话超时管理等。
  2. 定时任务:例如系统的定时任务、游戏中的定时事件、智能家居中的定时控制等。
  3. 缓存过期检查:缓存系统中,可以使用时间轮来高效地处理大量缓存项目的过期检查。

三、复杂业务环境下的时间轮应用示例

下面是一个简单的Java实现的时间轮示例,可以处理延迟任务。我们假设每个槽代表一秒:

public class TimingWheel {
    private int tick = 1; // 当前时间刻度
    private int wheelSize = 60; // 时间轮大小,即60个槽
    private Map<Integer, List<Runnable>> wheel = new HashMap<>(); // 时间轮

    // 添加任务
    public void addTask(int delay, Runnable task) {
        int key = (tick + delay) % wheelSize;
        if (!wheel.containsKey(key)) {
            wheel.put(key, new ArrayList<>());
        }
        wheel.get(key).add(task);
    }

    // 时间推进
    public void advance() {
        tick = (tick + 1) % wheelSize;
        if (wheel.containsKey(tick)) {
            for (Runnable task : wheel.get(tick)) {
                new Thread(task).start(); // 执行任务
            }
            wheel.remove(tick); // 移除已执行的任务
        }
    }
}

我们可以创建一个时间轮,然后添加一些延迟任务:

TimingWheel timingWheel = new TimingWheel();

// 添加一个5秒后执行的任务
timingWheel.addTask(5, () -> System.out.println("5 seconds task executed"));

// 添加一个30秒后执行的任务
timingWheel.addTask(30, () -> System.out.println("30 seconds task executed"));

// 模拟时间的推进
for (int i = 0; i < 60; i++) {
    timingWheel.advance();
    Thread.sleep(1000); // 休眠1秒,模拟真实时间的推进
}

以上即为时间轮在业务场景下的应用,它可以在不同的环境和场景下有不同的实现和优化,但其核心原理和设计方法是相同的。掌握了时间轮,你就可以更好地处理各种定时和延迟任务了。

然而,真正的业务环境可能会比这个例子更为复杂。例如,你可能需要处理更长的时间范围,或者需要处理大量的并发任务。在这种情况下,你可能需要实现一个层次化的时间轮,它包含多个级别的时间轮,每个级别代表不同的时间粒度。

此外,你可能还需要处理任务的取消或重新调度。这就需要在时间轮中维护一个任务到其在时间轮中位置的映射,这样你就可以快速找到并更新或删除任务。

下面是一个稍微复杂一点的时间轮的实现,它添加了任务取消的功能:

public class TimingWheel {
    private int tick = 1;
    private int wheelSize = 60;
    private Map<Integer, List<Task>> wheel = new HashMap<>();
    private Map<String, Integer> taskMap = new HashMap<>();

    // 任务类
    private static class Task {
        String id;
        Runnable runnable;

        Task(String id, Runnable runnable) {
            this.id = id;
            this.runnable = runnable;
        }
    }

    // 添加任务
    public void addTask(int delay, String taskId, Runnable task) {
        int key = (tick + delay) % wheelSize;
        if (!wheel.containsKey(key)) {
            wheel.put(key, new ArrayList<>());
        }
        wheel.get(key).add(new Task(taskId, task));
        taskMap.put(taskId, key);
    }

    // 取消任务
    public void cancelTask(String taskId) {
        if (taskMap.containsKey(taskId)) {
            int key = taskMap.get(taskId);
            wheel.get(key).removeIf(task -> task.id.equals(taskId));
            taskMap.remove(taskId);
        }
    }

    // 时间推进
    public void advance() {
        tick = (tick + 1) % wheelSize;
        if (wheel.containsKey(tick)) {
            for (Task task : wheel.get(tick)) {
                new Thread(task.runnable).start();
                taskMap.remove(task.id);
            }
            wheel.remove(tick);
        }
    }
}

你可以在这个基础上根据自己的需求进行扩展和优化。

四、总结

在本文中,我们详细地讨论了时间轮(Timing Wheel)这一数据结构,首先阐述了时间轮的基本定义,即用于管理需要在未来某个时间点执行的定时任务的数据结构。我们了解到,时间轮特别适用于处理那些可以容忍一些时间误差的任务,如网络连接超时检查、缓存项目的过期等。

接着,我们探讨了时间轮的应用场景,例如超时处理、定时任务和缓存过期检查。每一个场景都具有其独特性,需要时间轮来进行高效的处理。

最后,我们提供了Java语言实现的时间轮示例,包括基础版本和增加任务取消功能的高级版本,通过这些实例,我们可以看到时间轮在实际场景中是如何运用的,也可以根据实际需求对其进行扩展和优化。

总的来说,理解并掌握时间轮,能够帮助我们更好地处理各种定时和延迟任务,提升系统性能。

相关推荐

豆包编程能力升级:支持HTML代码实时预览、交互

IT之家3月19日消息,IT之家从豆包官方获悉,豆包宣布AI编程功能迎来三项升级,包括HTML预览、Python运行、生成完整项目。据介绍,目前豆包支持HTML代码实时预览和交互...

1898款游戏!80、90回忆杀,重温旧梦,快速搭建中文DOS游戏服务

本内容来源于@什么值得买APP,观点仅代表作者本人|作者:羊刀仙大家好,我是羊刀仙。本期来介绍一个特别情怀向的游戏项目:chinese-dos-games。这套包含1898款经典中文DOS游戏的合集...

利用 SVG 文件内的 HTML 代码进行网络钓鱼攻击

随着时间的推移,网络钓鱼攻击的技术越来越精妙,旨在欺骗用户并规避安全措施。攻击者会使用欺骗性的URL重定向策略,例如将恶意网站地址附加到看似安全的链接后,在PDF中嵌入链接,以及发送HTML...

aardio + AI 大模型自动编写 Python 代码、网页前端代码的经验与技巧

在AI时代,老式的编程习惯完全被颠覆。原来可能要一大堆插件或工具辛苦堆出来的程序,现在只要把AI调教好了就行。aardio支持调用十几种编程语言,这很适合发挥AI大模型的优势。对于AI...

用AI制作游戏就是如此简单!

很多人不知道如何利用AI提高效率,不知道AI能帮我们做什么,其实可以让我们实现很多自己根本不懂的领域取得直观体验,比如利用DS或者豆包,输入“我想做一个简单的单机俄罗斯方块游戏”,AI会给出phtho...

不会写代码?教你用DeepSeek 三步做出小游戏

如今,借助人工智能技术,哪怕你完全看不懂代码,也能通过DeepSeek制作出属于自己的网页版大鱼吃小鱼游戏。接下来,就为大家详细介绍制作过程。第一步、向DeepSeek描述需求为何要做网页版的...

《暗黑1》被移植成网页游戏 可在浏览器上玩了

《暗黑1》,这款1996年发售的“鼠标杀手”砍杀游戏,现在可以在浏览器上玩了。国外专注暴雪游戏的Rivsoft分享了一个《暗黑1》的共享版本,该版本只包含地下城的头2个地区和三个角色职业中的一个。不...

网页代码过滤 轻松获取专辑目录

通过过滤网页代码,可以将网页上显示不全的长文件名列表完整地提取出来。我有一个含有75个视频文件的《中医诊断学》课件,文件名是以01.RMVB、02.RMVB……75.RMVB这种格式命名的。我希望能找...

IDEA 2021首个大版本发布,Java开发者感动哭了(附新亮点演示)

工欲善其事,必先利其器!就在不久之前,Java领域的开发神器IntelliJIDEA终于迎来2021年的一个重要的大版本更新:IntelliJIDEA2021.1。现如今大量的Java开发者深度...

View Source:在 iOS 上轻松查看网页源代码

在移动互联网时代,移动端的应用和web体验都尤为重要,在PC上有很多web前端工具可以选择,而在移动端貌似就少之又少了,在NEXT出现的ViewSource能帮你在iOS上查看...

当我们《寻找房祖名》,我们能找到什么?

游戏葡萄原创专稿,未经允许请勿转载柯震东,因为在九把刀电影《那些年我们追过的女孩》中饰演男主角柯景腾而走红的台湾影星,在昨天被爆出了和著名演员成龙之子房祖名吸毒被抓的丑闻,一时间相关讨论席卷社交网络。...

多用途游戏娱乐新闻网站HTML5模板

Retnews是一个响应式的HTML新闻,博客,杂志网站模板,可以使用这套前端模板简约很多设计的工作。模板有许多特性适合流行的主题商业、时尚,游戏,娱乐,生活方式、体育、科技、政治、旅行、天气、视频等...

简约好看的个人引导页HTML源码下载

源码介绍一款非常简约好看的个人引导页HTML源码,非常适合个人主页以及个人导航使用,纯HTML不需要数据库,上传服务器即可使用!...

教你如何在微信公共平台上插入小游戏(图文教程)

很多玩微信公共平台的朋友都想在公共平台上面插入几个小游戏,用来跟用户之间互动,这里花生来分享一下如何在微信公共平台上插入游戏,以及如何制作html5微信小游戏。首先是找游戏,总共有三个方法,本人比较倾...

html5重力感应剖析附源码

下面是测试html5重力感应的demohttp://bbs.qietu.com/html/zhongli/http://www.qietu.com/html/f2/qqqianbao/demo2是切图...