parallel

Documentation

Index

• func BatchParallel(nJobs, nWorkers, batchSize int, ...) error
• func DynamicParallel(nJobs int, jobsAlloc *task.JobsAllocator, ...) error
• func Parallel(nJobs, nWorkers int, worker func(workerId, jobId int) error) error
• type ConditionChannel
  • func NewConditionChannel() *ConditionChannel
  • func (c *ConditionChannel) Close()
  • func (c *ConditionChannel) Signal()

Functions

func BatchParallel

func BatchParallel(nJobs, nWorkers, batchSize int, worker func(workerId, beginJobId, endJobId int) error) error

BatchParallel run parallel jobs in batches to reduce the cost of context switch.

func DynamicParallel

func DynamicParallel(nJobs int, jobsAlloc *task.JobsAllocator, worker func(workerId, jobId int) error) error

func Parallel

func Parallel(nJobs, nWorkers int, worker func(workerId, jobId int) error) error

Parallel schedules and runs tasks in parallel. nTask is the number of tasks. nJob is the number of executors. worker is the executed function which passed a range of task Names (begin, end).

Types

type ConditionChannel

type ConditionChannel struct {
	C chan struct{} // output channel
	// contains filtered or unexported fields
}

func NewConditionChannel

func NewConditionChannel() *ConditionChannel

func (*ConditionChannel) Close

func (c *ConditionChannel) Close()

func (*ConditionChannel) Signal

func (c *ConditionChannel) Signal()