guard_pool

Documentation

Index

• Constants
• type BaseLimiter
• type GoWorker
• type GuardPool
  • func NewPool(count int) *GuardPool
  • func (r *GuardPool) AsyncSubmit(task TaskFunc)
  • func (r *GuardPool) GetRunningCount() int
  • func (r *GuardPool) Pause()
  • func (r *GuardPool) Recover()
  • func (r *GuardPool) Release()
  • func (r *GuardPool) Start()
  • func (r *GuardPool) Submit(task TaskFunc)
• type IntervalLimiter
  • func NewIntervalLimiter(interval time.Duration) *IntervalLimiter
• type TaskFunc
• type TempoLimiter
  • func NewTempoLimit(limit, second int32) *TempoLimiter
  • func (t *TempoLimiter) Hit() bool

Constants

const (
	Running = iota
	Pending
	Over
	Idle
)

Types

type BaseLimiter

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

type GoWorker

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

type GuardPool

type GuardPool struct {
	RunningSheet map[string]*GoWorker
	IdleSheet    map[string]*GoWorker
	RunningChan  chan *GoWorker
	IdleChan     chan *GoWorker
	StatusChan   chan *GoWorker
	TaskFuncChan chan TaskFunc
	// contains filtered or unexported fields
}

func NewPool

func NewPool(count int) *GuardPool

func (*GuardPool) AsyncSubmit

func (r *GuardPool) AsyncSubmit(task TaskFunc)

func (*GuardPool) GetRunningCount

func (r *GuardPool) GetRunningCount() int

func (*GuardPool) Pause

func (r *GuardPool) Pause()

func (*GuardPool) Recover

func (r *GuardPool) Recover()

func (*GuardPool) Release

func (r *GuardPool) Release()

func (*GuardPool) Start

func (r *GuardPool) Start()

func (*GuardPool) Submit

func (r *GuardPool) Submit(task TaskFunc)

type IntervalLimiter

type IntervalLimiter struct {
	BaseLimiter
	// contains filtered or unexported fields
}

func NewIntervalLimiter

func NewIntervalLimiter(interval time.Duration) *IntervalLimiter

type TaskFunc

type TaskFunc func()

type TempoLimiter

type TempoLimiter struct {
	Limit      int32
	SecondSpan int32

	BaseLimiter
	// contains filtered or unexported fields
}

func NewTempoLimit

func NewTempoLimit(limit, second int32) *TempoLimiter

func (*TempoLimiter) Hit

func (t *TempoLimiter) Hit() bool