workerpool

Documentation

Index

• type Work
• type WorkerPool
  • func NewWorkerPool(size int) *WorkerPool
  • func (w *WorkerPool) Add(work Work)
  • func (w *WorkerPool) AddSync(work Work)
  • func (w *WorkerPool) Wait()

Types

type Work

type Work = func()

type WorkerPool

type WorkerPool struct {
	Size int
	// contains filtered or unexported fields
}

func NewWorkerPool

func NewWorkerPool(size int) *WorkerPool

NewWorkerPool returns a new WorkerPool, pool size is size.

func (*WorkerPool) Add

func (w *WorkerPool) Add(work Work)

Add adds a work to WorkerPool, asynchronously.

func (*WorkerPool) AddSync

func (w *WorkerPool) AddSync(work Work)

AddSync adds a work to WorkerPool, synchronously.

func (*WorkerPool) Wait

func (w *WorkerPool) Wait()

Wait waits for all tasks in workerpool to finish.