xdelay

Documentation

Index

• type Engine
  • func NewEngine(slotCount int) *Engine
  • func (e *Engine) AddTask(seconds uint, callback TaskCallback, params ...interface{}) error
  • func (e *Engine) Close()
  • func (e *Engine) GetTaskDistribution() (curIdx int, cnt []int)
  • func (e *Engine) Start()
• type TaskCallback

Types

type Engine

type Engine struct {
	// contains filtered or unexported fields
}

func NewEngine

func NewEngine(slotCount int) *Engine

创建一个延迟消息

func (*Engine) AddTask

func (e *Engine) AddTask(seconds uint, callback TaskCallback, params ...interface{}) error

添加任务

func (*Engine) Close

func (e *Engine) Close()

关闭延迟消息

func (*Engine) GetTaskDistribution

func (e *Engine) GetTaskDistribution() (curIdx int, cnt []int)

任务分布

func (*Engine) Start

func (e *Engine) Start()

启动延迟消息

type TaskCallback

type TaskCallback func(args ...interface{})

执行的任务函数