routine_pool

Documentation

Index

• Constants
• type GoWorker
• type LimitRoutinePool
  • func NewLimitPool(count int, limit int, notice func()) *LimitRoutinePool
• type RoutinePool
  • func NewPool(count int) *RoutinePool
  • func (r *RoutinePool) GetRunningCount() int
  • func (r *RoutinePool) Pause()
  • func (r *RoutinePool) Recover()
  • func (r *RoutinePool) Release()
  • func (r *RoutinePool) Start()
  • func (r *RoutinePool) Submit(task TaskFunc)
• type TaskFunc

Constants

const (
	Running = iota
	Pending
	Over
	Idle
)

Types

type GoWorker

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

type LimitRoutinePool

type LimitRoutinePool struct {
	*RoutinePool
	// contains filtered or unexported fields
}

func NewLimitPool

func NewLimitPool(count int, limit int, notice func()) *LimitRoutinePool

type RoutinePool

type RoutinePool 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) *RoutinePool

func (*RoutinePool) GetRunningCount

func (r *RoutinePool) GetRunningCount() int

func (*RoutinePool) Pause

func (r *RoutinePool) Pause()

func (*RoutinePool) Recover

func (r *RoutinePool) Recover()

func (*RoutinePool) Release

func (r *RoutinePool) Release()

func (*RoutinePool) Start

func (r *RoutinePool) Start()

func (*RoutinePool) Submit

func (r *RoutinePool) Submit(task TaskFunc)

type TaskFunc

type TaskFunc func()