pool

Documentation

Index

• func Init()
• func SetDefaultJobQueueLen(length int)
• func SetDefaultWorkerCount(count int)
• func SetWorkerPool(p *Pool)
• type Job
• type Pool
  • func GetWorkerPool() *Pool
  • func NewPool(workerCount, jobQueueLen int) *Pool
  • func (p *Pool) AddJob(job Job)
  • func (p *Pool) Start()
  • func (p *Pool) Stop()
  • func (p *Pool) Wait()
• type Worker
  • func NewWorker(id int, jobQueue chan Job) *Worker

Functions

func Init

func Init()

Init 初始化协程池

func SetDefaultJobQueueLen

func SetDefaultJobQueueLen(length int)

SetDefaultJobQueueLen 设置默认job queue长度

func SetDefaultWorkerCount

func SetDefaultWorkerCount(count int)

SetDefaultWorkerCount 设置默认worker数量

func SetWorkerPool

func SetWorkerPool(p *Pool)

SetWorkerPool 设置worker pool

Types

type Job

type Job func()

type Pool

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

func GetWorkerPool

func GetWorkerPool() *Pool

GetWorkerPool 获取worker pool

func NewPool

func NewPool(workerCount, jobQueueLen int) *Pool

func (*Pool) AddJob

func (p *Pool) AddJob(job Job)

func (*Pool) Start

func (p *Pool) Start()

func (*Pool) Stop

func (p *Pool) Stop()

func (*Pool) Wait

func (p *Pool) Wait()

type Worker

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

func NewWorker

func NewWorker(id int, jobQueue chan Job) *Worker