worker

Documentation

Index

• type LimitPool
  • func NewLimitPool(capacity int) *LimitPool
  • func (p *LimitPool) Add(task func())
  • func (p *LimitPool) Stop()
• type StaticPool
  • func NewStaticPool(capacity int) *StaticPool
  • func (p *StaticPool) Add(task func())
  • func (p *StaticPool) Stop()

Types

type LimitPool

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

LimitPool 带并发控制的协程池

func NewLimitPool

func NewLimitPool(capacity int) *LimitPool

NewLimitPool 新的LimitPool

func (*LimitPool) Add

func (p *LimitPool) Add(task func())

Add 增加新任务

func (*LimitPool) Stop

func (p *LimitPool) Stop()

Stop 结束任务

type StaticPool

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

StaticPool 固定协程个数的协程池

func NewStaticPool

func NewStaticPool(capacity int) *StaticPool

NewStaticPool 初始化固定容量的协程池

func (*StaticPool) Add

func (p *StaticPool) Add(task func())

Add 新增任务

func (*StaticPool) Stop

func (p *StaticPool) Stop()

Stop 结束任务