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
• func Split[T any](a []T, n int) [][]T
• type ConditionChannel
  • func NewConditionChannel() *ConditionChannel
  • func (c *ConditionChannel) Close()
  • func (c *ConditionChannel) Signal()
• type Future
  • func Async(f func()) *Future
  • func (f *Future) Wait()

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).

func Split

func Split[T any](a []T, n int) [][]T

Split a slice into n slices and keep the order of elements.

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()

type Future

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

func Async

func Async(f func()) *Future

func (*Future) Wait

func (f *Future) Wait()