concurrent

package

v4.47.1 Latest Latest Go to latest Published: Sep 3, 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.