Namespace: OtlParallel

Class TOmniPipelineStage

System.TInterfacedObject
  |
  +-- OtlParallel.TOmniPipelineStage
All Implemented Interfaces:
IOmniPipelineStage , IOmniPipelineStageEx

public class TOmniPipelineStage ( System.TInterfacedObject , IOmniPipelineStage , IOmniPipelineStageEx )

Sealed
False
Abstract
False
Persistent
False

Property Summary
  public  boolean HandleExceptions
 
  public  OtlCollections.IOmniBlockingCollection Input
 
  public  integer NumTasks
 
  public  OtlCollections.IOmniBlockingCollection Output
 
  public  IOmniTaskConfig TaskConfig
 
  public  integer Throttle
 
  public  integer ThrottleLow
 
  public  integer ThrottleLowSat
 
 

Constructor Summary
Create(stage: TPipelineSimpleStageDelegate ; taskConfig: IOmniTaskConfig )
 
Create(stage: TPipelineStageDelegate ; taskConfig: IOmniTaskConfig )
 
Create(stage: TPipelineStageDelegateEx ; taskConfig: IOmniTaskConfig )
 
 

Method Summary
  public Sub Execute(task: OtlTask.IOmniTask )
 
  public Sub SetQueues(inQueue: OtlCollections.IOmniBlockingCollection ; outQueue: OtlCollections.IOmniBlockingCollection )
 
 

Property Detail

HandleExceptions

public HandleExceptions: boolean
Type
boolean
Class
False
Access
read/write

Input

public Input: OtlCollections.IOmniBlockingCollection 
Type
IOmniBlockingCollection
Class
False
Access
read

NumTasks

public NumTasks: integer
Type
integer
Class
False
Access
read/write

Output

public Output: OtlCollections.IOmniBlockingCollection 
Type
IOmniBlockingCollection
Class
False
Access
read

TaskConfig

public TaskConfig: IOmniTaskConfig 
Type
IOmniTaskConfig
Class
False
Access
read

Throttle

public Throttle: integer
Type
integer
Class
False
Access
read/write

ThrottleLow

public ThrottleLow: integer
Type
integer
Class
False
Access
read/write

ThrottleLowSat

public ThrottleLowSat: integer
Type
integer
Class
False
Access
read/write

Constructor Detail

Create

public constructor Create(stage: TPipelineSimpleStageDelegate ; taskConfig: IOmniTaskConfig )
Final
False
Reintroduce
False
Virtual
False
Override
False
Abstract
False

Create

public constructor Create(stage: TPipelineStageDelegate ; taskConfig: IOmniTaskConfig )
Final
False
Reintroduce
False
Virtual
False
Override
False
Abstract
False

Create

public constructor Create(stage: TPipelineStageDelegateEx ; taskConfig: IOmniTaskConfig )
Final
False
Reintroduce
False
Virtual
False
Override
False
Abstract
False

Method Detail

Execute

public procedure Execute(task: OtlTask.IOmniTask )
Final
False
Reintroduce
False
Abstract
False
Override
False
Virtual
False
Class
False

SetQueues

public procedure SetQueues(inQueue: OtlCollections.IOmniBlockingCollection ; outQueue: OtlCollections.IOmniBlockingCollection )
Final
False
Reintroduce
False
Abstract
False
Override
False
Virtual
False
Class
False

Implementation Link

to Interface IOmniPipelineStage

Client
TOmniPipelineStage
Supplier
IOmniPipelineStage

to Interface IOmniPipelineStageEx

Client
TOmniPipelineStage
Supplier
IOmniPipelineStageEx

Association Link

to Interface IOmniBlockingCollection

Supplier
IOmniBlockingCollection
Directed
False
Client
opsInput
Type
association

to Interface IOmniBlockingCollection

Supplier
IOmniBlockingCollection
Directed
False
Client
opsOutput
Type
association

to Delegate TPipelineSimpleStageDelegate

Supplier
TPipelineSimpleStageDelegate
Directed
False
Client
opsSimpleStage
Type
association

to Delegate TPipelineStageDelegate

Supplier
TPipelineStageDelegate
Directed
False
Client
opsStage
Type
association

to Delegate TPipelineStageDelegateEx

Supplier
TPipelineStageDelegateEx
Directed
False
Client
opsStageEx
Type
association

to Interface IOmniTaskConfig

Supplier
IOmniTaskConfig
Directed
False
Client
opsTaskConfig
Type
association

to Interface IOmniBlockingCollection

Supplier
IOmniBlockingCollection
Directed
False
Client
Input
Type
association

to Interface IOmniBlockingCollection

Supplier
IOmniBlockingCollection
Directed
False
Client
Output
Type
association

to Interface IOmniTaskConfig

Supplier
IOmniTaskConfig
Directed
False
Client
TaskConfig
Type
association