async

type Group ¶

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

Group has several workers, and the group can execute these workers concurrently, wait for the workers to finish within a specified time, and receive the results returned by these workers.

func NewGroup(ctx context.Context) *Group

func (g *Group) Add(w func(stopCh chan interface{}))

func (g *Group) Wait() []error