一个Hash Wheel Timer是一个环形结构,可以想象成时钟,分为很多格子,一个格子代表一段时间(越短Timer精度越高),并用一个List保存在该格子上到期的所有任务,同时一个指针随着时间流逝一格一格转动,并执行对应List中所有到期的任务。
这个类一般用来处理大量的定时任务且任务对时间精度要求相对不高, 比如链接超时管理等场景, 缺点是, 内存占用相对较高.该类中有两个重要的参数
Tick Duration:即一个格子代表的时间,默认为100ms,因为IO事件不需要那么精确;
这个类一般用来处理大量的定时任务且任务对时间精度要求相对不高, 比如链接超时管理等场景, 缺点是, 内存占用相对较高.该类中有两个重要的参数
Tick Duration:即一个格子代表的时间,默认为100ms,因为IO事件不需要那么精确;
Ticks per Wheel (Wheel Size):一个Wheel含有多少个格子,默认为512个,如果任务较多可以增大这个参数.
package com.netty.demo001;
import java.util.concurrent.TimeUnit;
import org.jboss.netty.util.HashedWheelTimer;
import org.jboss.netty.util.Timeout;
import org.jboss.netty.util.TimerTask;
public class NettyTimerTask {
//定义HashedWheelTimer对象
//1000毫秒跳到下一个solt,一共有512个solt
static HashedWheelTimer timer=new HashedWheelTimer(5000L, TimeUnit.MILLISECONDS, 512);
public static void main(String[] args) {
TimerTask task=new TimerTask() {
@Override
public void run(Timeout timeout) throws Exception {
System.out.println("---run service-----");
//任务执行完成后再把自己添加到任务solt上
addTask(this);
}
};
addTask(task);
}
public static void addTask(TimerTask task){
//根据时长把task任务放到响应的solt上
timer.newTimeout(task, 500, TimeUnit.MILLISECONDS);
}
}
版权声明:本文为wangyang_software原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。