timer

Documentation

Index

• Constants
• func TickSafeMode() optionCall
• type Task
• type TaskID
• type TimeWheel
  • func NewTimeWheel(tick time.Duration, bucketNum int, options ...optionCall) (*TimeWheel, error)
  • func (tw *TimeWheel) AddTask(taskName string, delay time.Duration, callback func(), cronTask bool) error
  • func (tw *TimeWheel) GenUniqueId() TaskID
  • func (tw *TimeWheel) RemoveTask(taskName string) error
  • func (tw *TimeWheel) Start()
  • func (tw *TimeWheel) Stop()

Constants

const (
	CIRCLE_MODE     = true
	NOT_CIRCLE_MODE = false
	SYNC_MODE       = true
)

Functions

func TickSafeMode

func TickSafeMode() optionCall

Types

type Task

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

type TaskID

type TaskID int64

type TimeWheel

type TimeWheel struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewTimeWheel

func NewTimeWheel(tick time.Duration, bucketNum int, options ...optionCall) (*TimeWheel, error)

func (*TimeWheel) AddTask

func (tw *TimeWheel) AddTask(taskName string, delay time.Duration, callback func(), cronTask bool) error

AddTask

func (*TimeWheel) GenUniqueId

func (tw *TimeWheel) GenUniqueId() TaskID

func (*TimeWheel) RemoveTask

func (tw *TimeWheel) RemoveTask(taskName string) error

RemoveTask

func (*TimeWheel) Start

func (tw *TimeWheel) Start()

func (*TimeWheel) Stop

func (tw *TimeWheel) Stop()