multi_threader

Documentation

Index

• type Pool
  • func NewPool(ctx context.Context, threaderNum int, isPrint bool) *Pool
  • func (p *Pool) EnablePrint(enable bool) *Pool
  • func (p *Pool) Run(_func poolFunc)
  • func (p *Pool) Stop()

Types

type Pool

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

Pool 线程池

threaderNum 开启线程数量,范围1~可用的逻辑 CPU 数
inChan 输入通道
outChan 输出通道
arg 用户配置

func NewPool

func NewPool(ctx context.Context, threaderNum int, isPrint bool) *Pool

NewPool 创建线程池

threaderNum 开启线程数量,范围1~可用的逻辑 CPU 数
arg 用户配置

func (*Pool) EnablePrint

func (p *Pool) EnablePrint(enable bool) *Pool

EnablePrint 设置是否输出日志内容

func (*Pool) Run

func (p *Pool) Run(_func poolFunc)

Run 运行

productFun 生产者函数 返回待处理数据集切片
consumerFun 消费者函数，入参为索引和处理者返回数据
handleFun 处理者函数，入参为生产者返回数据集中的每个元素

func (*Pool) Stop

func (p *Pool) Stop()

Stop 停止方法