parallel

Index ¶

• func Run(tasks []types.FuncReturnErr) error
• func RunIgnoreError(tasks []types.FuncReturnErr) error
• func RunReturnData[T any](tasks []types.FuncReturnDataOrErr[T]) ([]T, error)
• type Option
• type Parallel
• • func New(workNum uint, opts ...Option) *Parallel
• • func (p *Parallel) AddFunc(task types.FuncRetry)
  • func (p *Parallel) AddTask(task interfaces.TaskRetry)
  • func (p *Parallel) Stop()
  • func (p *Parallel) Wait()
• type TaskChain
• • func (t *TaskChain) Do(times uint) bool