Namespace: OtlParallel

Class TOmniParallelLoop<T>

System.TInterfacedObject
  |
  +-- OtlParallel.TOmniParallelLoopBase 
    |
    +-- OtlParallel.TOmniParallelLoop<T>

All Implemented Interfaces:

IOmniParallelLoop<T> , IOmniParallelAggregatorLoop<T> , IOmniParallelInitializedLoop<T> , IOmniParallelIntoLoop<T>

public class TOmniParallelLoop<T> ( TOmniParallelLoopBase , IOmniParallelLoop<T> , IOmniParallelAggregatorLoop<T> , IOmniParallelInitializedLoop<T> , IOmniParallelIntoLoop<T> )

Generic Parameters

T

Sealed

False

Abstract

False

Persistent

False

Constructor Summary

Create(enumerator: TEnumeratorDelegate<T> )

Create(enumerator: TEnumerator<T>)

 

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	Destroy()
public Sub	Execute(loopBody: TOmniIteratorDelegate<T> )
public Sub	Execute(loopBody: TOmniIteratorTaskDelegate<T> )
public Sub	Execute(loopBody: TOmniIteratorIntoDelegate<T> )
public Sub	Execute(loopBody: TOmniIteratorIntoTaskDelegate<T> )
public Sub	Execute(loopBody: TOmniIteratorStateDelegate<T> )
public Sub	Execute(loopBody: TOmniIteratorStateTaskDelegate<T> )
public function OtlCommon.TOmniValue	ExecuteAggregate(loopBody: TOmniIteratorIntoDelegate<T> )
public function OtlCommon.TOmniValue	ExecuteAggregate(loopBody: TOmniIteratorIntoTaskDelegate<T> )
public function IOmniParallelInitializedLoop<T>	Finalize(taskFinalizer: TOmniTaskFinalizerDelegate )
public function IOmniParallelInitializedLoop<T>	Initialize(taskInitializer: TOmniTaskInitializerDelegate )
public function IOmniParallelIntoLoop<T>	Into(queue: OtlCollections.IOmniBlockingCollection )
public procedure	IOmniParallelAggregatorLoop.Execute()
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 )

 

Constructor Detail

Create

public constructor Create(enumerator: TEnumeratorDelegate<T> )

Final

False

Reintroduce

False

Virtual

False

Override

False

Abstract

False

public constructor Create(enumerator: TEnumerator<T>)

Final

False

Reintroduce

False

Virtual

False

Override

False

Abstract

False

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

Final

False

Reintroduce

False

Abstract

False

Returns

IOmniParallelAggregatorLoop<T>

Override

False

Virtual

False

Class

False

public function AggregateSum(): IOmniParallelAggregatorLoop<T> 

Final

False

Reintroduce

False

Abstract

False

Returns

IOmniParallelAggregatorLoop<T>

Override

False

Virtual

False

Class

False

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

Final

False

Reintroduce

False

Abstract

False

Returns

IOmniParallelLoop<T>

Override

False

Virtual

False

Class

False

public procedure Destroy()

Reintroduce

False

Virtual

False

Override

True

Abstract

False

Final

False

public procedure Execute(loopBody: TOmniIteratorDelegate<T> )

Final

False

Reintroduce

False

Abstract

False

Override

False

Virtual

False

Class

False

public procedure Execute(loopBody: TOmniIteratorTaskDelegate<T> )

Final

False

Reintroduce

False

Abstract

False

Override

False

Virtual

False

Class

False

public procedure Execute(loopBody: TOmniIteratorIntoDelegate<T> )

Final

False

Reintroduce

False

Abstract

False

Override

False

Virtual

False

Class

False

public procedure Execute(loopBody: TOmniIteratorIntoTaskDelegate<T> )

Final

False

Reintroduce

False

Abstract

False

Override

False

Virtual

False

Class

False

public procedure Execute(loopBody: TOmniIteratorStateDelegate<T> )

Final

False

Reintroduce

False

Abstract

False

Override

False

Virtual

False

Class

False

public procedure Execute(loopBody: TOmniIteratorStateTaskDelegate<T> )

Final

False

Reintroduce

False

Abstract

False

Override

False

Virtual

False

Class

False

public function ExecuteAggregate(loopBody: TOmniIteratorIntoDelegate<T> ): OtlCommon.TOmniValue 

Final

False

Reintroduce

False

Abstract

False

Returns

TOmniValue

Override

False

Virtual

False

Class

False

public function ExecuteAggregate(loopBody: TOmniIteratorIntoTaskDelegate<T> ): OtlCommon.TOmniValue 

Final

False

Reintroduce

False

Abstract

False

Returns

TOmniValue

Override

False

Virtual

False

Class

False

public function Finalize(taskFinalizer: TOmniTaskFinalizerDelegate ): IOmniParallelInitializedLoop<T> 

Final

False

Reintroduce

False

Abstract

False

Returns

IOmniParallelInitializedLoop<T>

Override

False

Virtual

False

Class

False

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

Final

False

Reintroduce

False

Abstract

False

Returns

IOmniParallelInitializedLoop<T>

Override

False

Virtual

False

Class

False

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

Final

False

Reintroduce

False

Abstract

False

Returns

IOmniParallelIntoLoop<T>

Override

False

Virtual

False

Class

False

public procedure IOmniParallelAggregatorLoop.Execute()

Final

False

Reintroduce

False

Abstract

False

Override

False

Virtual

False

Class

False

public function NoWait(): IOmniParallelLoop<T> 

Final

False

Reintroduce

False

Abstract

False

Returns

IOmniParallelLoop<T>

Override

False

Virtual

False

Class

False

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

Final

False

Reintroduce

False

Abstract

False

Returns

IOmniParallelLoop<T>

Override

False

Virtual

False

Class

False

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

Final

False

Reintroduce

False

Abstract

False

Returns

IOmniParallelLoop<T>

Override

False

Virtual

False

Class

False

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

Final

False

Reintroduce

False

Abstract

False

Returns

IOmniParallelLoop<T>

Override

False

Virtual

False

Class

False

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

Final

False

Reintroduce

False

Abstract

False

Returns

IOmniParallelLoop<T>

Override

False

Virtual

False

Class

False

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

Final

False

Reintroduce

False

Abstract

False

Returns

IOmniParallelLoop<T>

Override

False

Virtual

False

Class

False

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

Final

False

Reintroduce

False

Abstract

False

Returns

IOmniParallelLoop<T>

Override

False

Virtual

False

Class

False

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

Final

False

Reintroduce

False

Abstract

False

Returns

IOmniParallelLoop<T>

Override

False

Virtual

False

Class

False

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

Final

False

Reintroduce

False

Abstract

False

Returns

IOmniParallelLoop<T>

Override

False

Virtual

False

Class

False

public function PreserveOrder(): IOmniParallelLoop<T> 

Final

False

Reintroduce

False

Abstract

False

Returns

IOmniParallelLoop<T>

Override

False

Virtual

False

Class

False

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

Final

False

Reintroduce

False

Abstract

False

Returns

IOmniParallelLoop<T>

Override

False

Virtual

False

Class

False

Implementation Link

to Interface IOmniParallelLoop<T>

Client

TOmniParallelLoop

Supplier

IOmniParallelLoop

Client

TOmniParallelLoop

Supplier

IOmniParallelAggregatorLoop

Client

TOmniParallelLoop

Supplier

IOmniParallelInitializedLoop

Client

TOmniParallelLoop

Supplier

IOmniParallelIntoLoop

Generalization Link

to Class TOmniParallelLoopBase

Client

TOmniParallelLoop

Supplier

TOmniParallelLoopBase

Association Link

to Class TOmniDelegateEnumerator<T>

Supplier

TOmniDelegateEnumerator

Directed

False

Client

FDelegateEnum

Type

association