workerpool

Documentation

Index

• type Task
• type WorkerPool
  • func NewWorkerPool(size int) *WorkerPool
  • func (p *WorkerPool) AddTask(task Task)
  • func (p *WorkerPool) CloseAndWait() []error

Types

type Task

type Task func() error

type WorkerPool

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

func NewWorkerPool

func NewWorkerPool(size int) *WorkerPool

func (*WorkerPool) AddTask

func (p *WorkerPool) AddTask(task Task)

func (*WorkerPool) CloseAndWait

func (p *WorkerPool) CloseAndWait() []error