time

type E ¶

type E string

E is the internal error type

func (e E) Error() string

type PeriodicSleeper ¶

type PeriodicSleeper interface {
	Sleep(d time.Duration)
	Reset()
}

PeriodicSleeper 用在以下场景: 每次 sleep 结束之后, 当指定下一次 sleep 时长 T 时, 不会 完全按照 T 来 sleep, 而是参照自身上一次 sleep 的预期时间 tₙ₋₁ + T 来 sleep。这与 Tick 类似, 不同的是每次 sleep 的时间需要重新指定。

需要注意的是: 如果 tₙ₋₁ + T 小于当前时间, 则会触发一次 Reset 动作之后再 + T

func NewPeriodicSleeper() PeriodicSleeper

type Tick ¶

type Tick interface {
	Run()
	Stop()
	SetCallback(fn TickCallback)
}

Tick 提供一个长期尽可能周期性的 tick

func NewTickBeta(interval time.Duration, callback TickCallback) (Tick, error)

type TickCallback ¶

type TickCallback func(param TickCallbackParam)

type TickCallbackParam ¶

type TickCallbackParam struct {
}

type TimeoutCallback ¶

type TimeoutCallback func()

TimeoutCallback 表示超时时的回调函数

type Timer ¶

type Timer interface {
	// Run starts timer in the background.
	Run() error

	// Stop stops the timer if it is running.
	Stop() error

	// Running check whether timer is running.
	Running() bool

	// Remain returns remaining time in the timer
	Remain() time.Duration

	// Elapsed returns elapsed time in the timer
	Elapsed() time.Duration
}

Timer is re-packaged time.Timer object, but have different methods.

func NewTimer(d time.Duration, cb TimeoutCallback) Timer