worker_pool

Jun 23, 2022

Changes in this version

+ type Pool struct

+ IsAborted bool

+ func New(numWorkers, numTasks int) *Pool

+ func (pool *Pool) Add(task Task)

+ func (pool *Pool) Start()

+ func (pool *Pool) Wait() <-chan struct{}

+ type Task interface

+ Run func(send func(string), abort func())