The highest tagged major version is v2.

parallel

package

v1.0.0 Latest Latest Go to latest Published: Apr 1, 2020 License: MIT Imports: 3 Imported by: 1

Details

This section is empty.

This section is empty.

func Close()

func Init(workercount int)

func Run(task Task, waiter *Waiter)

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

func New(workercount int) *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

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

func NewWaiter() *Waiter

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

func (w *Waiter) Wait()