Namespace: OtlParallel

Interface IOmniParallelLoop<T>

All Known Implementing Classes:

TOmniParallelLoop<T>

public interface IOmniParallelLoop<T>

Generic Parameters

T

Persistent

False

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

 

Method Detail

Aggregate

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

Reintroduce

False

Returns

IOmniParallelAggregatorLoop<T>

public function AggregateSum(): IOmniParallelAggregatorLoop<T> 

Reintroduce

False

Returns

IOmniParallelAggregatorLoop<T>

public function CancelWith(token: OtlSync.IOmniCancellationToken ): IOmniParallelLoop<T> 

Reintroduce

False

Returns

IOmniParallelLoop<T>

public procedure Execute(loopBody: TOmniIteratorDelegate<T> )

Reintroduce

False

public procedure Execute(loopBody: TOmniIteratorTaskDelegate<T> )

Reintroduce

False

public function Initialize(taskInitializer: TOmniTaskInitializerDelegate ): IOmniParallelInitializedLoop<T> 

Reintroduce

False

Returns

IOmniParallelInitializedLoop<T>

public function Into(queue: OtlCollections.IOmniBlockingCollection ): IOmniParallelIntoLoop<T> 

Reintroduce

False

Returns

IOmniParallelIntoLoop<T>

public function NoWait(): IOmniParallelLoop<T> 

Reintroduce

False

Returns

IOmniParallelLoop<T>

public function NumTasks(taskCount: integer): IOmniParallelLoop<T> 

Reintroduce

False

Returns

IOmniParallelLoop<T>

public function OnMessage(eventDispatcher: TObject): IOmniParallelLoop<T> 

Reintroduce

True

Returns

IOmniParallelLoop<T>

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

Reintroduce

True

Returns

IOmniParallelLoop<T>

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

Reintroduce

True

Returns

IOmniParallelLoop<T>

public function OnStop(stopCode: TProc): IOmniParallelLoop<T> 

Reintroduce

False

Returns

IOmniParallelLoop<T>

public function OnStop(stopCode: TOmniTaskStopDelegate ): IOmniParallelLoop<T> 

Reintroduce

False

Returns

IOmniParallelLoop<T>

public function OnTaskCreate(taskCreateDelegate: TOmniTaskCreateDelegate ): IOmniParallelLoop<T> 

Reintroduce

False

Returns

IOmniParallelLoop<T>

public function OnTaskCreate(taskCreateDelegate: TOmniTaskControlCreateDelegate ): IOmniParallelLoop<T> 

Reintroduce

False

Returns

IOmniParallelLoop<T>

public function PreserveOrder(): IOmniParallelLoop<T> 

Reintroduce

False

Returns

IOmniParallelLoop<T>

public function TaskConfig(config: IOmniTaskConfig ): IOmniParallelLoop<T> 

Reintroduce

False

Returns

IOmniParallelLoop<T>