concurrent

package

v0.5.5 Latest Latest Go to latest Published: Jul 14, 2026 License: MIT Imports: 2 Imported by: 0

Documentation ¶

This section is empty.

This section is empty.

This section is empty.

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

WorkerPool represents a pool of workers that can process jobs concurrently

func NewWorkerPool(workerCount int) *WorkerPool

NewWorkerPool creates a new worker pool with the specified number of workers

func (wp *WorkerPool) Run(ctx context.Context, functions ...func() error) error

Run executes all functions using errgroup with goroutine limiting Returns the first error encountered, and cancels remaining work