parallel

Documentation

Overview

Package parallel provides a bounded goroutine pool for concurrent API calls.

Index

• type Pool
  • func New(n int) *Pool
  • func (p *Pool) Go(fn func())
  • func (p *Pool) GoErr(fn func() error)
  • func (p *Pool) Wait() []error

Types

type Pool

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

Pool runs at most N goroutines concurrently.

func New

func New(n int) *Pool

New creates a Pool with concurrency limit n (minimum 1).

func (*Pool) Go

func (p *Pool) Go(fn func())

Go submits fn for execution, blocking until a slot is available.

func (*Pool) GoErr

func (p *Pool) GoErr(fn func() error)

GoErr submits fn; any returned error is collected and returned by Wait.

func (*Pool) Wait

func (p *Pool) Wait() []error

Wait blocks until all submitted functions complete. Returns any errors collected from GoErr calls.