worker

package

v0.29.4-dev-56e4e32 Latest Latest Go to latest Published: Nov 3, 2025 License: AGPL-3.0 Imports: 1 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

Pool manages a pool of worker goroutines.

func NewPool(numWorkers int) *Pool

NewPool creates a new Pool with a specified number of workers.

func (p *Pool) Stop()

Stop stops all the workers and waits for them to finish.

func (p *Pool) Submit(task Task)

Submit adds a task to the worker pool.

type Task func()

Task represents a unit of work to be processed by the worker pool.