Class AbstractParallelScheduler

Hierarchy

AbstractParallelScheduler
- DefaultParallelScheduler

Implements

IParallelJobScheduler

Index

Methods

Methods

getScheduling

getScheduling(totalNumberOfValues: number, options: IDefaultInitializedParallelOptions): IParallelTaskScheduling

- Defined in common/parallel/scheduling/abstract-parallel-scheduler.ts:24
Returns the suggested scheduling for the given number of values - while concerning the passed in options.

Parameters
- totalNumberOfValues: number
  
  the total number of values to be processed by the parallel operation chain
- options: IDefaultInitializedParallelOptions
  
  the parallel options provided for this operation chain
Returns IParallelTaskScheduling

Private getTaskDefinitions

getTaskDefinitions(job: IParallelJob): ITaskDefinition[]

- Defined in common/parallel/scheduling/abstract-parallel-scheduler.ts:26
Parameters
- job: IParallelJob
Returns ITaskDefinition[]

schedule

schedule<TResult>(job: IParallelJob): ITask<TResult>[]

Implementation of IParallelJobScheduler.schedule
- Defined in common/parallel/scheduling/abstract-parallel-scheduler.ts:14
Type parameters
- TResult
Parameters
- job: IParallelJob
Returns ITask<TResult>[]

Private serializeOperations

serializeOperations(operations: IParallelOperation[], functionCallSerializer: FunctionCallSerializer): Array<object>

- Defined in common/parallel/scheduling/abstract-parallel-scheduler.ts:64
Parameters
- operations: IParallelOperation[]
- functionCallSerializer: FunctionCallSerializer
Returns Array<object>

Generated using TypeDoc