wp

Documentation

Overview

Package wp provides a simple worker pool.

Index

• type WorkerPool
  • func New() *WorkerPool
  • func (p *WorkerPool) Close()
  • func (p *WorkerPool) Drain()
  • func (p *WorkerPool) Init()

Types

type WorkerPool

type WorkerPool struct {
	// Number of concurrent workers (default: 1).
	// If negative, spawns a goroutine for each task.
	NumWorkers int
	// Task queue (default: buffered channel with 128 capacity).
	Tasks chan func()
	// contains filtered or unexported fields
}

WorkerPool manages a pool of goroutines that process tasks from a queue.

func New

func New() *WorkerPool

New creates and starts the default worker pool.

func (*WorkerPool) Close

func (p *WorkerPool) Close()

Close stops all the workers and waits for them to exit.

func (*WorkerPool) Drain

func (p *WorkerPool) Drain()

Drain closes Tasks channel and waits for the workers to process remaining tasks and exit.

func (*WorkerPool) Init

func (p *WorkerPool) Init()

Init initializes and starts the worker pool.