ProcessQueueTCreateAsynchronousQueue(ProcessQueueTProcessItemsFunctionSignature, ProcessQueueTCanProcessItemFunctionSignature, Int32) Method

Creates a new asynchronous, bulk item ProcessQueueT with the default settings: ProcessInterval = 100, ProcessTimeout = Infinite, RequeueOnTimeout = False, RequeueOnException = False.

Definition

Namespace: Gemstone.Threading.Collections
Assembly: Gemstone.Threading (in Gemstone.Threading.dll) Version: 1.0.138 -- Release Build+45b5271a2dafa59bb75ccbb6019faabf2c5f392a
public static ProcessQueue<T> CreateAsynchronousQueue(
	ProcessQueueTProcessItemsFunctionSignature processItemsFunction,
	ProcessQueueTCanProcessItemFunctionSignature canProcessItemFunction,
	int maximumThreads
)

Parameters

processItemsFunction  ProcessQueueTProcessItemsFunctionSignature
Delegate that defines a method to process multiple items at once.
canProcessItemFunction  ProcessQueueTCanProcessItemFunctionSignature
Delegate which determines whether an item can be processed.
maximumThreads  Int32
An Int32 value that determines the maximum number of threads used to process items.

Return Value

ProcessQueueT
A ProcessQueue object based on type T.

See Also