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.141 -- Release Build+5e2ec463438f5de09767d41cb13e56e90c503d09
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