+ +
+ +
+
+
+
+
+
+
+ + +

Class AsyncQueue<T> +

+

A simple asynchronous multi-thread supporting producer/consumer FIFO queue with minimal locking.

+
+
+
+
Inheritance
+
Object
+
AsyncQueue<T>
+
+
+
Inherited Members
+ + + + + + + +
+
Namespace: Advanced.Algorithms.Distributed
+
Assembly: Advanced.Algorithms.dll
+
Syntax
+
+ 
public class AsyncQueue<T>
+
+
Type Parameters
+ + + + + + + + + + + + + +
NameDescription
T
+

Methods +

+ + + +

DequeueAsync(CancellationToken)

+

Supports multi-threaded consumers. +Time complexity: O(1).

+
+
+
Declaration
+
+ 
public Task<T> DequeueAsync(CancellationToken taskCancellationToken = default(CancellationToken))
+
+
Parameters
+ + + + + + + + + + + + + + + +
TypeNameDescription
CancellationTokentaskCancellationToken
+
Returns
+ + + + + + + + + + + + + +
TypeDescription
Task<T>
+ + + +

EnqueueAsync(T, CancellationToken)

+

Supports multi-threaded producers. +Time complexity: O(1).

+
+
+
Declaration
+
+ 
public Task EnqueueAsync(T value, CancellationToken taskCancellationToken = default(CancellationToken))
+
+
Parameters
+ + + + + + + + + + + + + + + + + + + + +
TypeNameDescription
Tvalue
CancellationTokentaskCancellationToken
+
Returns
+ + + + + + + + + + + + + +
TypeDescription
Task
+
+
+ + +
+