routine

Documentation

Index

• func ExecRoutineWithInterval(name string, routine RoutineFn, interval time.Duration)
• func StartWorkingRoutine(workers []WorkingRoutine) error
• type CountLimiter
  • func (limit *CountLimiter) Count() uint32
  • func (limit *CountLimiter) Decr()
  • func (limit *CountLimiter) Incr()
  • func (limit *CountLimiter) IncrIfNotFull() bool
  • func (limit *CountLimiter) IsFull() bool
• type RoutineFn
  • func WorkingRoutineWrapper(name string, fn RoutineFn, interval time.Duration) RoutineFn
• type WorkingRoutine

Functions

func ExecRoutineWithInterval

func ExecRoutineWithInterval(
	name string,
	routine RoutineFn,
	interval time.Duration,
)

定期执行工作例程

func StartWorkingRoutine

func StartWorkingRoutine(workers []WorkingRoutine) error

启动所有的工作例程

Types

type CountLimiter

type CountLimiter struct {
	UpperLimit uint32 // the upper limit
	// contains filtered or unexported fields
}

count limiter

func (*CountLimiter) Count

func (limit *CountLimiter) Count() uint32

return the current count

func (*CountLimiter) Decr

func (limit *CountLimiter) Decr()

decr the count

func (*CountLimiter) Incr

func (limit *CountLimiter) Incr()

incr the count

func (*CountLimiter) IncrIfNotFull

func (limit *CountLimiter) IncrIfNotFull() bool

if the count don't exceed the upper limit, incr the count return if incr the count

func (*CountLimiter) IsFull

func (limit *CountLimiter) IsFull() bool

check if the count exceeds the upper limit

type RoutineFn

type RoutineFn func()

例程类型

func WorkingRoutineWrapper

func WorkingRoutineWrapper(name string, fn RoutineFn, interval time.Duration) RoutineFn

工作例程包装函数

type WorkingRoutine

type WorkingRoutine struct {
	RoutineFn    RoutineFn     // 工作例程函数
	RoutineCount uint          // 例程数量
	Interval     time.Duration // 工作例程的执行间隔
}

工作例程结构