Class AsyncQueue<T>
A simple asynchronous multi-thread supporting producer/consumer FIFO queue with minimal locking.
Inheritance
AsyncQueue<T>
Assembly: Advanced.Algorithms.dll
Syntax
public class AsyncQueue<T>
Type Parameters
Properties
Count
Declaration
public int Count { get; }
Property Value
Methods
DequeueAsync(Int32, CancellationToken)
Supports multi-threaded consumers.
Time complexity: O(1).
Declaration
public Task<T> DequeueAsync(int millisecondsTimeout = 2147483647, CancellationToken taskCancellationToken = default(CancellationToken))
Parameters
Returns
EnqueueAsync(T, Int32, CancellationToken)
Supports multi-threaded producers.
Time complexity: O(1).
Declaration
public Task EnqueueAsync(T value, int millisecondsTimeout = 2147483647, CancellationToken taskCancellationToken = default(CancellationToken))
Parameters
Returns