Documentation
¶
Index ¶
- func AddMoreTimesTask(interval, times int64, immediately bool, taskName string, taskHandel Execute, ...) error
- func AddOnceTask(interval int64, taskName string, taskHandel Execute, args ...interface{}) error
- func AddRepeatTask(interval int64, immediately bool, taskName string, taskHandel Execute, ...) error
- func NewTimeWheel(interval time.Duration, numSlots int) *timeWheel
- func RemoveTask(taskName string)
- type Execute
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AddMoreTimesTask ¶
func AddMoreTimesTask(interval, times int64, immediately bool, taskName string, taskHandel Execute, args ...interface{}) error
*
- @description: 定时执行n次任务
- @param {int64} interval-->间隔时间
- @param {int64} times-->执行次数
- @param {bool} immediately-->是否立即执行一次
- @param {string} taskName-->任务名称，时轮中已经存在改任务，则丢弃此次任务
- @param {Execute} taskHandel-->任务执行函数体
- @param {...interface{}} args-->任务执行函数入参
- @return {*}
func AddOnceTask ¶
*
- @description: 延后执行一次任务
- @param {int64} interval-->延后时间，单位s
- @param {string} taskName-->任务名称，时轮中已经存在改任务，则丢弃此次任务
- @param {Execute} taskHandel-->任务执行函数体
- @param {...interface{}} args-->任务执行函数入参
- @return {*}
func AddRepeatTask ¶
func AddRepeatTask(interval int64, immediately bool, taskName string, taskHandel Execute, args ...interface{}) error
*
- @description: 定时执行无限次任务
- @param {int64} interval-->间隔时间
- @param {bool} immediately-->是否立即执行一次
- @param {string} taskName-->任务名称，时轮中已经存在改任务，则丢弃此次任务
- @param {Execute} taskHandel-->任务执行函数体
- @param {...interface{}} args-->任务执行函数入参
- @return {*}
func NewTimeWheel ¶
*
- @description: 创建时轮
- @param {time.Duration} interval-->时轮推荐间隔，一般使用各类业务所需最细粒度时间
- @param {int} numSlots -->时轮插槽数，一个时轮总时长interval*numSlots
- @return {*timeWheel} 时轮对象
func RemoveTask ¶
func RemoveTask(taskName string)
*
- @description: 中途停止任务
- @param {string} taskName-->任务名称
Types ¶
Source Files
Click to show internal directories.
Click to hide internal directories.