pool

Jun 29, 2023

Changes in this version

type Parallel

+ func (q *Parallel[T]) WaitAll()

Jun 18, 2023

Changes in this version

+ type Parallel struct

+ func NewParallel(maxWorkers int, capacity int) *Parallel[T]

+ func (q *Parallel[T]) Enqueue(item T) bool

+ func (q *Parallel[T]) EnqueueWithTimeout(item T, timeout time.Duration) bool

+ func (q *Parallel[T]) Start(processor func(T)) error

+ func (q *Parallel[T]) Stop()

+ func (q *Parallel[T]) Submit(item T)

Jun 15, 2023

Changes in this version

type WorkerPool

+ func (q *WorkerPool[T]) Enqueue(task Task[T]) bool

+ func (q *WorkerPool[T]) EnqueueWithTimeout(task Task[T], timeout time.Duration) bool

+ func (q *WorkerPool[T]) Start(callback func(T)) error

+ func (q *WorkerPool[T]) Stop()

+ func (q *WorkerPool[T]) Submit(task Task[T])

Jun 5, 2023

Changes in this version

+ type Task interface

+ Run func() any

+ type Worker struct

+ func NewWorker(workerPool chan chan Task, quit chan bool, rc *int64, results chan any) *Worker

+ func (w Worker) Start()

+ type WorkerPool struct

+ func NewWorkerPool(workers int, size int, results chan any) *WorkerPool

+ func (t *WorkerPool) Close()

+ func (t *WorkerPool) Execute(task Task) error

+ func (t *WorkerPool) WaitForAll()