workerpool

package

v0.5.0 Latest Latest Go to latest Published: Dec 19, 2023 License: Apache-2.0 Imports: 3 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

This section is empty.

type Executor interface {
	Start(worker *Worker)
}

Executor is the unit of work that executes a task.

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

Pool manages and limits the number of concurrent Worker.

func Initialize(name string) *Pool

Initialize creates a new Pool with a name and the number of parallel workers it will use.

func (p *Pool) ActiveWorkers() int

ActiveWorkers gives the number of active workers on the Pool.

func (p *Pool) AppendExecutor(executor Executor)

AppendExecutor adds a new Executor to the queue of Executor to be processed.

func (p *Pool) Start()

Start the Pool.

func (p *Pool) Stop()

Stop the Pool and wait for all the pending Worker to complete.

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

Worker takes an executor and starts the actual executor.

func NewWorker(id int, name string) *Worker

NewWorker instantiates a new worker with an ID and name.

func (w *Worker) Start(executorQueue <-chan Executor)

Start gets an executor queue and starts working on it.