concurrent

Documentation

Index

• type Group
  • func NewGroup(limit uint64) *Group
  • func (g *Group) Go(f func() error)
  • func (g *Group) Wait() error
  • func (g *Group) WithContext(ctx context.Context) context.Context

Types

type Group

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

Group describes a task group with a fail-fast approach

func NewGroup

func NewGroup(limit uint64) *Group

NewGroup creates a Group with given concurrency limit

func (*Group) Go

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

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

func (*Group) Wait

func (g *Group) Wait() error

Wait for Group to end

func (*Group) WithContext

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

WithContext make the given context cancelable for the group