cn.hutool.cron.timingwheel

Class TimerTaskList

java.lang.Object

cn.hutool.cron.timingwheel.TimerTaskList

All Implemented Interfaces:

Comparable<Delayed>, Delayed

public class TimerTaskList
extends Object
implements Delayed

任务队列，任务双向链表

Author:

siran.yao，looly

Constructor Summary

Constructors

Constructor and Description
TimerTaskList() 构造

Method Summary

Modifier and Type	Method and Description
void	addTask(TimerTask timerTask) 新增任务，将任务加入到双向链表的头部
int	compareTo(Delayed o)
void	flush(Consumer<TimerTask> flush) 重新分配，即将列表中的任务全部处理
long	getDelay(TimeUnit unit)
long	getExpire() 获取过期时间
void	removeTask(TimerTask timerTask) 移除任务
boolean	setExpiration(long expire) 设置过期时间

Methods inherited from class java.lang.Object

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

Constructor Detail

TimerTaskList

public TimerTaskList()

构造

Method Detail

setExpiration

public boolean setExpiration(long expire)

设置过期时间

Parameters:

expire - 过期时间，单位毫秒

Returns:

是否设置成功

getExpire

public long getExpire()

获取过期时间

Returns:

过期时间

addTask

public void addTask(TimerTask timerTask)

新增任务，将任务加入到双向链表的头部

Parameters:

timerTask - 延迟任务

removeTask

public void removeTask(TimerTask timerTask)

移除任务

Parameters:

timerTask - 任务

flush

public void flush(Consumer<TimerTask> flush)

重新分配，即将列表中的任务全部处理

Parameters:

flush - 任务处理函数

getDelay

public long getDelay(TimeUnit unit)

Specified by:

getDelay in interface Delayed

compareTo

public int compareTo(Delayed o)

Specified by:

compareTo in interface Comparable<Delayed>