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.174 -- Release Build+6575dd693dbd5e3d5a41dd1450ccb8ddc2885703
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