waitgroup

Documentation

Index

• type Group
  • func New(max uint) *Group
  • func WithContext(ctx context.Context, max uint) (*Group, context.Context)
  • func (g *Group) Go(fn func() error)
  • func (g *Group) Wait() error

Types

type Group

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

Like sync.WaitGroup but with error handling and concurrency limits.

func New

func New(max uint) *Group

Create a group without context.

func WithContext

func WithContext(ctx context.Context, max uint) (*Group, context.Context)

Create a group with context.

func (*Group) Go

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

Run goroutines.

func (*Group) Wait

func (g *Group) Wait() error

Wait goroutines.