Namespace: OtlParallel

Interface IOmniParallelLoop

All Known Implementing Classes:

TOmniParallelLoop

public interface IOmniParallelLoop

Persistent

False

Method Summary
public function IOmniParallelAggregatorLoop	Aggregate(defaultAggregateValue: OtlCommon.TOmniValue ; aggregator: TOmniAggregatorDelegate )
public function IOmniParallelAggregatorLoop	AggregateSum()
public function IOmniParallelLoop	CancelWith(token: OtlSync.IOmniCancellationToken )
public Sub	Execute(loopBody: TOmniIteratorDelegate )
public Sub	Execute(loopBody: TOmniIteratorTaskDelegate )
public function IOmniParallelInitializedLoop	Initialize(taskInitializer: TOmniTaskInitializerDelegate )
public function IOmniParallelIntoLoop	Into(queue: OtlCollections.IOmniBlockingCollection )
public function IOmniParallelLoop	NoWait()
public function IOmniParallelLoop	NumTasks(taskCount: integer)
public function IOmniParallelLoop	OnMessage(eventDispatcher: TObject)
public function IOmniParallelLoop	OnMessage(msgID: word; eventHandler: OtlTaskControl.TOmniTaskMessageEvent )
public function IOmniParallelLoop	OnMessage(msgID: word; eventHandler: OtlTaskControl.TOmniOnMessageFunction )
public function IOmniParallelLoop	OnStop(stopCode: TProc)
public function IOmniParallelLoop	OnStop(stopCode: TOmniTaskStopDelegate )
public function IOmniParallelLoop	OnTaskCreate(taskCreateDelegate: TOmniTaskCreateDelegate )
public function IOmniParallelLoop	OnTaskCreate(taskCreateDelegate: TOmniTaskControlCreateDelegate )
public function IOmniParallelLoop	PreserveOrder()
public function IOmniParallelLoop	TaskConfig(config: IOmniTaskConfig )

 

Method Detail

Aggregate

public function Aggregate(defaultAggregateValue: OtlCommon.TOmniValue ; aggregator: TOmniAggregatorDelegate ): IOmniParallelAggregatorLoop 

Reintroduce

False

Returns

IOmniParallelAggregatorLoop

public function AggregateSum(): IOmniParallelAggregatorLoop 

Reintroduce

False

Returns

IOmniParallelAggregatorLoop

public function CancelWith(token: OtlSync.IOmniCancellationToken ): IOmniParallelLoop 

Reintroduce

False

Returns

IOmniParallelLoop

public procedure Execute(loopBody: TOmniIteratorDelegate )

Reintroduce

False

public procedure Execute(loopBody: TOmniIteratorTaskDelegate )

Reintroduce

False

public function Initialize(taskInitializer: TOmniTaskInitializerDelegate ): IOmniParallelInitializedLoop 

Reintroduce

False

Returns

IOmniParallelInitializedLoop

public function Into(queue: OtlCollections.IOmniBlockingCollection ): IOmniParallelIntoLoop 

Reintroduce

False

Returns

IOmniParallelIntoLoop

public function NoWait(): IOmniParallelLoop 

Reintroduce

False

Returns

IOmniParallelLoop

public function NumTasks(taskCount: integer): IOmniParallelLoop 

Reintroduce

False

Returns

IOmniParallelLoop

public function OnMessage(eventDispatcher: TObject): IOmniParallelLoop 

Reintroduce

True

Returns

IOmniParallelLoop

public function OnMessage(msgID: word; eventHandler: OtlTaskControl.TOmniTaskMessageEvent ): IOmniParallelLoop 

Reintroduce

True

Returns

IOmniParallelLoop

public function OnMessage(msgID: word; eventHandler: OtlTaskControl.TOmniOnMessageFunction ): IOmniParallelLoop 

Reintroduce

True

Returns

IOmniParallelLoop

public function OnStop(stopCode: TProc): IOmniParallelLoop 

Reintroduce

False

Returns

IOmniParallelLoop

public function OnStop(stopCode: TOmniTaskStopDelegate ): IOmniParallelLoop 

Reintroduce

False

Returns

IOmniParallelLoop

public function OnTaskCreate(taskCreateDelegate: TOmniTaskCreateDelegate ): IOmniParallelLoop 

Reintroduce

False

Returns

IOmniParallelLoop

public function OnTaskCreate(taskCreateDelegate: TOmniTaskControlCreateDelegate ): IOmniParallelLoop 

Reintroduce

False

Returns

IOmniParallelLoop

public function PreserveOrder(): IOmniParallelLoop 

Reintroduce

False

Returns

IOmniParallelLoop

public function TaskConfig(config: IOmniTaskConfig ): IOmniParallelLoop 

Reintroduce

False

Returns

IOmniParallelLoop