timer

package

v0.0.0-...-bfb5c6f Latest Latest Go to latest Published: Jul 10, 2018 License: Apache-2.0 Imports: 7 Imported by: 9

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/viphxin/xingo

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func UnixTS() int64
type DelayCall
- func (this *DelayCall) Call()
- func (this *DelayCall) String() string
type HashWheel
- func NewHashWheel(title string, level int, linterval int64, maxCap uint32) *HashWheel
type ParamNull
type SafeTimer
- func NewSafeTimer(delay int64, delayCall *DelayCall) *SafeTimer
type SafeTimerScheduel
- func NewSafeTimerScheduel() *SafeTimerScheduel
type Timer
- func NewTimer(durations time.Duration, f func(v ...interface{}), args []interface{}) *Timer

Constants ¶

View Source

const (
	//默认安全时间调度器的容量
	TIMERLEN = 2048
	//默认最大误差值100毫秒
	ERRORMAX = 100
	//默认最大触发队列缓冲大小
	TRIGGERMAX = 2048
	//默认hashwheel分级
	LEVEL = 12
)

协程安全的timer

View Source

const (
	DEFAULT_LEVEL = 12
)

Variables ¶

This section is empty.

Functions ¶

func UnixTS ¶

func UnixTS() int64

Types ¶

type DelayCall ¶

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

func (*DelayCall) Call ¶

func (this *DelayCall) Call()

func (*DelayCall) String ¶

func (this *DelayCall) String() string

type HashWheel ¶

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

func NewHashWheel ¶

func NewHashWheel(title string, level int, linterval int64, maxCap uint32) *HashWheel

func (*HashWheel) Add2WheelChain ¶

func (this *HashWheel) Add2WheelChain(tid uint32, t *SafeTimer) error

func (*HashWheel) AddNext ¶

func (this *HashWheel) AddNext(next *HashWheel)

func (*HashWheel) Count ¶

func (this *HashWheel) Count() int

func (*HashWheel) GetTriggerWithIn ¶

func (this *HashWheel) GetTriggerWithIn(ms int64) map[uint32]*SafeTimer

func (*HashWheel) RemoveFromWheelChain ¶

func (this *HashWheel) RemoveFromWheelChain(tid uint32)

func (*HashWheel) RunWheel ¶

func (this *HashWheel) RunWheel()

时间轮跑起来

type ParamNull ¶

type ParamNull struct{}

type SafeTimer ¶

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

func NewSafeTimer ¶

func NewSafeTimer(delay int64, delayCall *DelayCall) *SafeTimer

type SafeTimerScheduel ¶

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

func NewSafeTimerScheduel ¶

func NewSafeTimerScheduel() *SafeTimerScheduel

func (*SafeTimerScheduel) CancelTimer ¶

func (this *SafeTimerScheduel) CancelTimer(timerId uint32)

func (*SafeTimerScheduel) CreateTimer ¶

func (this *SafeTimerScheduel) CreateTimer(delay int64, f func(v ...interface{}), args []interface{}) (uint32, error)

func (*SafeTimerScheduel) GetTriggerChannel ¶

func (this *SafeTimerScheduel) GetTriggerChannel() chan *DelayCall

func (*SafeTimerScheduel) StartScheduelLoop ¶

func (this *SafeTimerScheduel) StartScheduelLoop()

type Timer ¶

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

func NewTimer ¶

func NewTimer(durations time.Duration, f func(v ...interface{}), args []interface{}) *Timer

func (*Timer) GetDurations ¶

func (this *Timer) GetDurations() time.Duration

func (*Timer) GetFunc ¶

func (this *Timer) GetFunc() *DelayCall

func (*Timer) Run ¶

func (this *Timer) Run()

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL