workerpool

Documentation

Index

• type Config
• type WorkerPool
  • func New(cfg Config) *WorkerPool
  • func (p *WorkerPool) AddTask(task func())
  • func (p *WorkerPool) Close()

Types

type Config

type Config struct {
	PoolSize        int
	TaskQueueLength int
}

type WorkerPool

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

func New

func New(cfg Config) *WorkerPool

func (*WorkerPool) AddTask

func (p *WorkerPool) AddTask(task func())

func (*WorkerPool) Close

func (p *WorkerPool) Close()