concurrent

package

v4.41.6 Latest Latest Go to latest Published: May 14, 2022 License: MIT Imports: 2 Imported by: 5

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

This section is empty.

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

FailFast describes a task group with a fail-fast approach

func NewFailFast(limit uint64) *FailFast

NewFailFast creates a Group with given concurrency limit

func (g *FailFast) Go(f func() error)

Go run given function in a goroutine according to limiter and current status

func (g *FailFast) Wait() error

Wait for Group to end

func (g *FailFast) WithContext(ctx context.Context) context.Context

WithContext make the given context cancelable for the group

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

Limited describes a task group with limited parallelism

func NewLimited(limit uint64) *Limited

NewLimited creates a Limited with given concurrency limit

func (g *Limited) Go(f func())

Go run given function in a goroutine according to limiter

func (g *Limited) Wait()

Wait for Limited to end

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

Simple describes a task group with simple parallelism

func NewSimple() *Simple

NewSimple creates a Simple concurrent pattern

func (g *Simple) Go(f func())

Go run given function in a goroutine

func (g *Simple) Wait()

Wait for Simple to end