Gemstone Threading Library
Show/Hide TOC

# ProcessQueue T CreateAsynchronousQueue(ProcessQueue T ProcessItemsFunctionSignature, ProcessQueue T CanProcessItemFunctionSignature, 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
C#
View Source Request Example

    public static ProcessQueue<T> CreateAsynchronousQueue(
    	ProcessQueueTProcessItemsFunctionSignature processItemsFunction,
    	ProcessQueueTCanProcessItemFunctionSignature canProcessItemFunction,
    	int maximumThreads
    )

VB
View Source Request Example

    Public Shared Function CreateAsynchronousQueue (
    	processItemsFunction As ProcessQueueTProcessItemsFunctionSignature,
    	canProcessItemFunction As ProcessQueueTCanProcessItemFunctionSignature,
    	maximumThreads As Integer
    ) As ProcessQueue(Of T)

C++
View Source Request Example

    public:
    static ProcessQueue<T>^ CreateAsynchronousQueue(
    	ProcessQueueTProcessItemsFunctionSignature^ processItemsFunction,
    	ProcessQueueTCanProcessItemFunctionSignature^ canProcessItemFunction,
    	int maximumThreads
    )

JavaScript
View Source Request Example

    Gemstone.Threading.Collections.ProcessQueue.CreateAsynchronousQueue = function(processItemsFunction, canProcessItemFunction, maximumThreads);

#### Parameters

processItemsFunction ProcessQueueT ProcessItemsFunctionSignature
  Delegate that defines a method to process multiple items at once.
canProcessItemFunction ProcessQueueT CanProcessItemFunctionSignature
  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

ProcessQueue T
A ProcessQueue object based on type T.

## See Also

#### Reference

ProcessQueueT Class
CreateAsynchronousQueue Overload
Gemstone.Threading.Collections Namespace