Overview  Namespace  Classifier  Tree  Index  Help 
PREV   NEXT FRAMES  NO FRAMES
SUMMARY: INNER | FIELD | CONSTR | DESTR | METHOD DETAIL: FIELD | CONSTR | DESTR | METHOD

Namespace: OtlParallel

Class TOmniPipeline

System.TInterfacedObject
  |
  +-- OtlParallel.TOmniPipeline
All Implemented Interfaces:
IOmniPipeline
public class TOmniPipeline ( System.TInterfacedObject , IOmniPipeline )

Sealed
False
Abstract
False
Persistent
False

Property Summary
  public  OtlCollections.IOmniBlockingCollection Input
 
  public  OtlCollections.IOmniBlockingCollection Output
 
  public  IOmniPipelineStage PipelineStage
 
 

Constructor Summary
Create()
 
 

Method Summary
  public Sub Cancel()
 
  public Sub Destroy()
 
  public function IOmniPipeline From(queue: OtlCollections.IOmniBlockingCollection )
 
  public function IOmniPipeline HandleExceptions()
 
  public function IOmniPipeline NoThrottling()
 
  public function IOmniPipeline NumTasks(numTasks: integer)
 
  public function IOmniPipeline OnStop(stopCode: TProc)
 
  public function IOmniPipeline OnStop(stopCode: TOmniTaskStopDelegate )
 
  public function IOmniPipeline Run()
 
  public function IOmniPipeline Stage(pipelineStage: TPipelineSimpleStageDelegate ; taskConfig: IOmniTaskConfig )
 
  public function IOmniPipeline Stage(pipelineStage: TPipelineStageDelegate ; taskConfig: IOmniTaskConfig )
 
  public function IOmniPipeline Stage(pipelineStage: TPipelineStageDelegateEx ; taskConfig: IOmniTaskConfig )
 
  public function IOmniPipeline Stages(pipelineStages: TPipelineSimpleStageDelegate ; taskConfig: IOmniTaskConfig )
 
  public function IOmniPipeline Stages(pipelineStages: TPipelineStageDelegate ; taskConfig: IOmniTaskConfig )
 
  public function IOmniPipeline Stages(pipelineStages: TPipelineStageDelegateEx ; taskConfig: IOmniTaskConfig )
 
  public function IOmniPipeline Throttle(numEntries: integer; unblockAtCount: integer)
 
  public function boolean WaitFor(timeout_ms: cardinal)
 
 

Property Detail

Input

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

Output

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

PipelineStage

public PipelineStage: IOmniPipelineStage
Type
IOmniPipelineStage
Class
False
Access
read
Constructor Detail

Create

public constructor Create()
Final
False
Reintroduce
False
Virtual
False
Override
False
Abstract
False
Method Detail

Cancel

public procedure Cancel()
Final
False
Reintroduce
False
Abstract
False
Override
False
Virtual
False
Class
False

Destroy

public procedure Destroy()
Reintroduce
False
Virtual
False
Override
True
Abstract
False
Final
False

From

public function From(queue: OtlCollections.IOmniBlockingCollection ): IOmniPipeline
Final
False
Reintroduce
False
Abstract
False
Returns
IOmniPipeline
Override
False
Virtual
False
Class
False

HandleExceptions

public function HandleExceptions(): IOmniPipeline
Final
False
Reintroduce
False
Abstract
False
Returns
IOmniPipeline
Override
False
Virtual
False
Class
False

NoThrottling

public function NoThrottling(): IOmniPipeline
Final
False
Reintroduce
False
Abstract
False
Returns
IOmniPipeline
Override
False
Virtual
False
Class
False

NumTasks

public function NumTasks(numTasks: integer): IOmniPipeline
Final
False
Reintroduce
False
Abstract
False
Returns
IOmniPipeline
Override
False
Virtual
False
Class
False

OnStop

public function OnStop(stopCode: TProc): IOmniPipeline
Final
False
Reintroduce
False
Abstract
False
Returns
IOmniPipeline
Override
False
Virtual
False
Class
False

OnStop

public function OnStop(stopCode: TOmniTaskStopDelegate ): IOmniPipeline
Final
False
Reintroduce
False
Abstract
False
Returns
IOmniPipeline
Override
False
Virtual
False
Class
False

Run

public function Run(): IOmniPipeline
Final
False
Reintroduce
False
Abstract
False
Returns
IOmniPipeline
Override
False
Virtual
False
Class
False

Stage

public function Stage(pipelineStage: TPipelineSimpleStageDelegate ; taskConfig: IOmniTaskConfig ): IOmniPipeline
Final
False
Reintroduce
False
Abstract
False
Returns
IOmniPipeline
Override
False
Virtual
False
Class
False

Stage

public function Stage(pipelineStage: TPipelineStageDelegate ; taskConfig: IOmniTaskConfig ): IOmniPipeline
Final
False
Reintroduce
False
Abstract
False
Returns
IOmniPipeline
Override
False
Virtual
False
Class
False

Stage

public function Stage(pipelineStage: TPipelineStageDelegateEx ; taskConfig: IOmniTaskConfig ): IOmniPipeline
Final
False
Reintroduce
False
Abstract
False
Returns
IOmniPipeline
Override
False
Virtual
False
Class
False

Stages

public function Stages(pipelineStages: TPipelineSimpleStageDelegate ; taskConfig: IOmniTaskConfig ): IOmniPipeline
Final
False
Reintroduce
False
Abstract
False
Returns
IOmniPipeline
Override
False
Virtual
False
Class
False

Stages

public function Stages(pipelineStages: TPipelineStageDelegate ; taskConfig: IOmniTaskConfig ): IOmniPipeline
Final
False
Reintroduce
False
Abstract
False
Returns
IOmniPipeline
Override
False
Virtual
False
Class
False

Stages

public function Stages(pipelineStages: TPipelineStageDelegateEx ; taskConfig: IOmniTaskConfig ): IOmniPipeline
Final
False
Reintroduce
False
Abstract
False
Returns
IOmniPipeline
Override
False
Virtual
False
Class
False

Throttle

public function Throttle(numEntries: integer; unblockAtCount: integer): IOmniPipeline
Final
False
Reintroduce
False
Abstract
False
Returns
IOmniPipeline
Override
False
Virtual
False
Class
False

WaitFor

public function WaitFor(timeout_ms: cardinal): boolean
Final
False
Reintroduce
False
Abstract
False
Returns
boolean
Override
False
Virtual
False
Class
False

Implementation Link

to Interface IOmniPipeline

Client
TOmniPipeline
Supplier
IOmniPipeline

Association Link

to Interface IOmniCancellationToken

Supplier
IOmniCancellationToken
Directed
False
Client
opCancelWith
Type
association

to Interface IOmniResourceCount

Supplier
IOmniResourceCount
Directed
False
Client
opCountStopped
Type
association

to Interface IOmniBlockingCollection

Supplier
IOmniBlockingCollection
Directed
False
Client
opInput
Type
association

to Class TOmniTaskStopDelegate

Supplier
TOmniTaskStopDelegate
Directed
False
Client
opOnStop
Type
association

to Interface IOmniBlockingCollection

Supplier
IOmniBlockingCollection
Directed
False
Client
opOutput
Type
association

to Class TOmniTransitionEvent

Supplier
TOmniTransitionEvent
Directed
False
Client
opShutDownComplete
Type
association

to Interface IOmniPipelineStageEx

Supplier
IOmniPipelineStageEx
Directed
False
Client
PipeStage
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 IOmniPipelineStage

Supplier
IOmniPipelineStage
Directed
False
Client
PipelineStage
Type
association

Overview  Namespace  Classifier  Tree  Index  Help 
PREV   NEXT FRAMES  NO FRAMES
SUMMARY: INNER | FIELD | CONSTR | DESTR | METHOD DETAIL: FIELD | CONSTR | DESTR | METHOD