pool

Documentation

Index

• type Pool
  • func CreatePool(poolWorkerNum int) *Pool
  • func (p *Pool) Run(taskNum int, isShowOption bool, graph string)

Types

type Pool

type Pool struct {
	//对外的Task进入通道
	EntryChannel chan *task.Task

	//对内的Task通道，用来去消费Task
	JobChannel chan *task.Task

	//用来定义协程池内消费任务的worker数，即可理解为需要启动多少个协程来消费任务
	PoolWorkerNum int
}

func CreatePool

func CreatePool(poolWorkerNum int) *Pool

CreatePool 创建一个协程池 @param poolWorkerNum int @return *Pool

func (*Pool) Run

func (p *Pool) Run(taskNum int, isShowOption bool, graph string)

Run 运行协程池 @receiver p *Pool @param taskNum int @param isShowOption bool @param graph string