org.voovan.tools.hashwheeltimer

Class HashWheelTimer

java.lang.Object

org.voovan.tools.hashwheeltimer.HashWheelTimer

public class HashWheelTimer
extends Object

时间轮定时器

Constructor Summary

Constructors

Constructor and Description
HashWheelTimer(int size) 构造函数 默认每槽的步长是1s
HashWheelTimer(int size, int tickStep) 构造函数
HashWheelTimer(String name, int size) 构造函数 默认每槽的步长是1s
HashWheelTimer(String name, int size, int tickStep) 构造函数

Method Summary

Modifier and Type	Method and Description
boolean	addTask(HashWheelTask task, int interval) 增加任务 同步方式执行
boolean	addTask(HashWheelTask task, int interval, boolean asynchronous) 增加任务
boolean	addTask(Runnable task, int interval) 增加任务 同步方式执行
boolean	addTask(Runnable task, int interval, boolean asynchronous) 增加任务
void	cancel() 停止时间轮的轮转
void	clear() 清理所有的任务 请注意系统任务也会被清理
boolean	removeTask(HashWheelTask task) 移除任务
boolean	rotate() 启动时间轮的轮转

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HashWheelTimer

public HashWheelTimer(int size)

构造函数 默认每槽的步长是1s

Parameters:

size - 时间轮的槽数

HashWheelTimer

public HashWheelTimer(int size,
                      int tickStep)

构造函数

Parameters:

size - 时间轮的槽数

tickStep - 每槽的步长, 单位: 毫秒

HashWheelTimer

public HashWheelTimer(String name,
                      int size)

构造函数 默认每槽的步长是1s

Parameters:

name - 时间轮定时器名称

size - 时间轮的槽数

HashWheelTimer

public HashWheelTimer(String name,
                      int size,
                      int tickStep)

构造函数

Parameters:

name - 时间轮定时器名称

size - 时间轮的槽数

tickStep - 每槽的步长, 单位: 毫秒

Method Detail

addTask

public boolean addTask(HashWheelTask task,
                       int interval)

增加任务 同步方式执行

Parameters:

task - 任务对象

interval - 任务间隔的槽数

Returns:

true 增加任务成功, false: 增加任务失败, 任务的Interval必须大于0

addTask

public boolean addTask(HashWheelTask task,
                       int interval,
                       boolean asynchronous)

增加任务

Parameters:

task - 任务对象

interval - 任务间隔的槽数

asynchronous - 是否异步执行

Returns:

true 增加任务成功, false: 增加任务失败, 任务的Interval必须大于0

addTask

public boolean addTask(Runnable task,
                       int interval)

增加任务 同步方式执行

Parameters:

task - 任务对象

interval - 任务间隔的槽数

Returns:

true 增加任务成功, false: 增加任务失败, 任务的Interval必须大于0

addTask

public boolean addTask(Runnable task,
                       int interval,
                       boolean asynchronous)

增加任务

Parameters:

task - 任务对象

interval - 任务间隔的槽数

asynchronous - 是否异步执行

Returns:

true 增加任务成功, false: 增加任务失败, 任务的Interval必须大于0

removeTask

public boolean removeTask(HashWheelTask task)

移除任务

Parameters:

task - 任务

Returns:

true:移除任务成功, false:移除任务失败,或任务不存在

rotate

public boolean rotate()

启动时间轮的轮转

Returns:

true:成功启动, false:时间轮已经启动

clear

public void clear()

清理所有的任务 请注意系统任务也会被清理

cancel

public void cancel()

停止时间轮的轮转