picker

Documentation

Index

• type Picker
  • func WithContext(ctx context.Context) (*Picker, context.Context)
  • func WithTimeout(ctx context.Context, timeout time.Duration) (*Picker, context.Context)
  • func WithoutAutoCancel(ctx context.Context) *Picker
  • func (p *Picker) Go(f func() (interface{}, error))
  • func (p *Picker) Wait() interface{}
  • func (p *Picker) WaitWithoutCancel() interface{}

Types

type Picker

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

Picker provides synchronization, and Context cancelation for groups of goroutines working on subtasks of a common task. Inspired by errGroup

func WithContext

func WithContext(ctx context.Context) (*Picker, context.Context)

WithContext returns a new Picker and an associated Context derived from ctx. and cancel when first element return.

func WithTimeout

func WithTimeout(ctx context.Context, timeout time.Duration) (*Picker, context.Context)

WithTimeout returns a new Picker and an associated Context derived from ctx with timeout.

func WithoutAutoCancel

func WithoutAutoCancel(ctx context.Context) *Picker

WithoutAutoCancel returns a new Picker and an associated Context derived from ctx, but it wouldn't cancel context when the first element return.

func (*Picker) Go

func (p *Picker) Go(f func() (interface{}, error))

Go calls the given function in a new goroutine. The first call to return a nil error cancels the group; its result will be returned by Wait.

func (*Picker) Wait

func (p *Picker) Wait() interface{}

Wait blocks until all function calls from the Go method have returned, then returns the first nil error result (if any) from them.

func (*Picker) WaitWithoutCancel

func (p *Picker) WaitWithoutCancel() interface{}

WaitWithoutCancel blocks until the first result return, if timeout will return nil.