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.158 -- Release Build+5f840a50b8123565ea38e0c1d6c00b5650022b4a
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