concurrent

Documentation

Index

• type WorkerPool
  • func NewWorkerPool(workerCount int) *WorkerPool
  • func (wp *WorkerPool) Run(ctx context.Context, functions ...func() error) error

Types

type WorkerPool

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

WorkerPool represents a pool of workers that can process jobs concurrently

func NewWorkerPool

func NewWorkerPool(workerCount int) *WorkerPool

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

func (*WorkerPool) Run

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