Dubbo 时间轮

dubbo-common 包中，有个比较有趣的功能 —— HashedWheelTimer，也就是时间轮。

它的源代码相对之前的 SPI 机制相对简单不少，只涉及三个 interface、一个 class 文件，如下图。

简单介绍下源代码

Timerout 抽象接口类。它定义了五个方法，有返回 Timer、返回 TimerTask，以及 TimerTask 状态相关的接口（是否过期、是否取消、取消）。

Timer 抽象接口类。它定义了三个方法，有定义延迟多久运行、取消所有还未运行的任务，以及判断是否已经停止的接口。

TimerTask 抽象接口类。它定义了一个 run 接口。

HashedWheelTimer 是 Timer 接口的实现类。

核心类 HashedWheelTimer 源码逻辑（部分）

1. 特殊常量们

它有很多的常量，相对特殊的有两种：以 Atomic 命名的原子类、LinkedBlockingQueue。

Atomic 命名的原子类能够保证，在多线程的运行环境中当某个线程在执行 Atomic 方法时，不会被其他线程打断。

例如：AtomicIntegerFieldUpdater，是通过反射机制来保证指定字段更新的原子性。

LinkedBlockingQueue，是基于链表（Linked）的可选容量的阻塞队列。具体实现包含了大量的 lock()、unlock() 代码。

2. 创建一个新的 Timer

3. 使用 CAS 的机制，来控制线程的 start、stop。

4. worker 内部类实现了Runable 接口。

5. HashedWheelTimeout 内部类实现了 Timeout 接口。其中重要的 cancel() 方法是将需要 cancel 的对象，添加到 cancelledTimeouts 队列之中。

cancelledTimeouts 对象的清理过程。

6. HashedWheelBucket 内部类实现了维护 HashedWheelTimeout 对象的添加、删除等方法。

总结

Dubbo 时间轮，涉及到了大量的多线程开发代码，对学习如何运用多线程有很大的帮助。