workerpool

package

v0.9.2 Latest Latest Go to latest Published: Mar 29, 2023 License: BSD-3-Clause Imports: 1 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Pool struct {
	Tasks   []*Task
	Workers []*Worker
	// contains filtered or unexported fields
}

A worker group that runs tasks at a configured concurrency.

func NewPool(tasks []*Task, concurrency int) *Pool

func (p *Pool) AddTask(task *Task)

Add a task to the pool.

func (p *Pool) Run()

Run all tasks in the pool and blocks until it's finished.

func (p *Pool) RunBackground()

Run the workers in background.

func (p *Pool) Stop()

Stop the background workers.

type Task struct {
	Err error
	// contains filtered or unexported fields
}

Encapsulate a task in a work pool.

func NewTask(f func(data interface{}) error, data interface{}) *Task

func (t *Task) Run()

type Worker struct {
	ID int
	// contains filtered or unexported fields
}

A worker handles the received tasks.

func NewWorker(id int, tasks chan *Task) *Worker

func (w *Worker) Start(wg *sync.WaitGroup)

Start the worker and do the tasks.

func (w *Worker) StartBackground()

Start the worker in background, waiting for tasks.

func (w *Worker) Stop()

Stop the background worker.