parallel

package

v1.2.9 Latest Latest Go to latest Published: Nov 25, 2025 License: Apache-2.0 Imports: 2 Imported by: 0

Details

Package parallel provides utilities for running tasks in parallel.

This section is empty.

This section is empty.

This section is empty.

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

Manager is a structure for running tasks in parallel.

func New(workercount int) *Manager

New creates a new parallel.Manager.

func (p *Manager) Close()

Close waits all tasks to finish.

func (p *Manager) Run(fn Task, waiter *Waiter)

Run runs the given task while limiting the concurrency.

type Task func() error

Task is a function type for parallel manager.

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

Waiter is a structure for waiting and reading error messages created by Manager.

func NewWaiter() *Waiter

NewWaiter creates a new parallel.Waiter.

func (w *Waiter) Err() <-chan error

Err returns read-only error channel.

func (w *Waiter) Wait()

Wait blocks until the WaitGroup counter is zero and closes error channel.