parallel

Documentation

Index

• func Serial(ctx context.Context, parallelizable Interface, tasks, routines, window int) error
• type Interface
• type Result

Functions

func Serial

func Serial(ctx context.Context, parallelizable Interface, tasks, routines, window int) error

Types

type Interface

type Interface interface {
	ParallelDo(ctx context.Context, routine, task int) (interface{}, error)
	ParallelCollect(result *Result) error
}

type Result

type Result struct {
	Routine int
	Task    int
	Value   interface{}
	// contains filtered or unexported fields
}