pool

package

v1.2.54 Latest Latest Go to latest Published: Jun 15, 2023 License: MIT Imports: 5 Imported by: 0

Details

This section is empty.

This section is empty.

func NewWorker[T any](id int, readyPool chan chan Task[T], done *sync.WaitGroup) *worker[T]

type Task[T any] interface {
	Run() T
}

Task is interface for any job executed by the worker pool

type WorkerPool[T any] struct {
	// contains filtered or unexported fields
}

func NewWorkerPool[T any](maxWorkers int, capacity int) *WorkerPool[T]

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

Enqueue submits a task to the buffered job queue without blocking, returns false if queue is full

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

EnqueueWithTimeout submits a task to the buffered job queue without blocking, returns false if queue is full within the duration

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

Start pool with optional callback to be invoked on task completion

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

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

Submit a task to the job queue, blocked if no workers are available