ProcessQueueTCreateAsynchronousQueue(ProcessQueueTProcessItemFunctionSignature, ProcessQueueTCanProcessItemFunctionSignature, Double, Int32, Int32, Boolean, Boolean) Method

Creates a new asynchronous ProcessQueueT using specified settings.

Definition

Namespace: Gemstone.Threading.Collections
Assembly: Gemstone.Threading (in Gemstone.Threading.dll) Version: 1.0.128 -- Release Build+d4a9a653be1def5888b9be91bb1825c8655f3529
public static ProcessQueue<T> CreateAsynchronousQueue(
	ProcessQueueTProcessItemFunctionSignature processItemFunction,
	ProcessQueueTCanProcessItemFunctionSignature canProcessItemFunction,
	double processInterval,
	int maximumThreads,
	int processTimeout,
	bool requeueOnTimeout,
	bool requeueOnException
)

Parameters

processItemFunction  ProcessQueueTProcessItemFunctionSignature
Delegate that processes one item at a time.
canProcessItemFunction  ProcessQueueTCanProcessItemFunctionSignature
Delegate which determines whether an item can be processed.
processInterval  Double
a Double value which represents the process interval in milliseconds.
maximumThreads  Int32
An Int32 value that determines the maximum number of threads used to process items.
processTimeout  Int32
The number of seconds before a process should timeout.
requeueOnTimeout  Boolean
A Boolean value that indicates whether a process should requeue an item on timeout.
requeueOnException  Boolean
A Boolean value that indicates whether a process should requeue after an exception.

Return Value

ProcessQueueT
A ProcessQueue object based on type T.

See Also