gpool

Documentation

Index

• type Job
• type Pool
  • func NewPool(numWorkers int, jobQueueLen int) *Pool
  • func (p *Pool) Release()
  • func (p *Pool) Start()
• type Worker
  • func (w *Worker) Start()

Types

type Job

type Job func()

Job is a function for doing jobs.

type Pool

type Pool struct {
	JobQueue    chan Job
	WorkerQueue chan *Worker
	// contains filtered or unexported fields
}

Pool is goroutine pool config.

func NewPool

func NewPool(numWorkers int, jobQueueLen int) *Pool

NewPool news goroutine pool

func (*Pool) Release

func (p *Pool) Release()

Release : release all workers

func (*Pool) Start

func (p *Pool) Start()

Start starts all workers

type Worker

type Worker struct {
	WorkerQueue chan *Worker
	JobChannel  chan Job
	Stop        chan struct{}
}

Worker goroutine struct.

func (*Worker) Start

func (w *Worker) Start()

Start : start goroutine pool.