Documentation
¶
Index ¶
- type ParallelOptions
- type ParallelTasks
- func (p *ParallelTasks) Add(tasks ...Task) *ParallelTasks
- func (p *ParallelTasks) Cancel(cancelReason error)
- func (p *ParallelTasks) Context(ctx context.Context) *ParallelTasks
- func (p *ParallelTasks) Do() *ParallelTasks
- func (p *ParallelTasks) FailFast() *ParallelTasks
- func (p *ParallelTasks) Name(name string) *ParallelTasks
- func (p *ParallelTasks) SetConcurrent(count int) *ParallelTasks
- func (p *ParallelTasks) Wait() ([]interface{}, error)
- type Task
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ParallelOptions ¶
type ParallelTasks ¶
type ParallelTasks struct {
Options ParallelOptions
Log *zap.SugaredLogger
// contains filtered or unexported fields
}
ParallelTasks will construct a parallel tasks struct you could execute tasks in parallel eg. result, err := P("eg1", f1,f2, f3).Do().Wait() result, err := P("eg2", f1,f2, f3).Add(f4).FailFast().Do().Wait()
result, err := P("eg3", f1,f2, f3).Context(func()context.Context{
ctx, _ := context.WithTimeout(context.Background(), 500*time.Millisecond) // 0.5s will timeout
return ctx
}).Do().Wait()
func P ¶
func P(log *zap.SugaredLogger, name string, tasks ...Task) *ParallelTasks
P will construct ParallelTasks name will be used for log you must care about the variable that referenced by Closure
func (*ParallelTasks) Add ¶
func (p *ParallelTasks) Add(tasks ...Task) *ParallelTasks
pts := P("eg")
for _, item := range itemArrar {
pts.Add(genTask(item))
}
func (*ParallelTasks) Cancel ¶
func (p *ParallelTasks) Cancel(cancelReason error)
func (*ParallelTasks) Context ¶
func (p *ParallelTasks) Context(ctx context.Context) *ParallelTasks
Context will set context , up to now , task is not support to cancel if you cancel from context, wait will return immediately
func (*ParallelTasks) Do ¶
func (p *ParallelTasks) Do() *ParallelTasks
Do will start to execute all task in parallel
func (*ParallelTasks) FailFast ¶
func (p *ParallelTasks) FailFast() *ParallelTasks
func (*ParallelTasks) Name ¶
func (p *ParallelTasks) Name(name string) *ParallelTasks
func (*ParallelTasks) SetConcurrent ¶
func (p *ParallelTasks) SetConcurrent(count int) *ParallelTasks
func (*ParallelTasks) Wait ¶
func (p *ParallelTasks) Wait() ([]interface{}, error)
Wait will wait all task executed, if set fail fast , it will return immediately if any task returns errors up to now , task is not support to cancel you should invoke Do() before invoke Wait() the result of task will be saved in []interface{} if you set failfast and one errors happened, it will return one error if you not set failfase and any errors happened, it will return []error as MultiErrors
Source Files