ConcurrentPriorityQueueT

A concurrent priority queue with parallelism.

Nuget Package: https://www.nuget.org/packages/ConcurrentPriorityQueueT/

Features

1. Fully concurrent, All operations are thread-safe.
2. Parallel enqueuing (threads do not lock the entire collection when enqueuing).
3. Specifying the type of priority queue (Min or Max).
4. Specifying if duplicates are allowed on enqueuing.
5. Utilizes the asynchronous programming model (APM) to invoke callbacks for asynchronous methods.

Complexity

Enqueue: O(n), Calling thread must wait until after iterating the list for correct placement.
EnqueueAsync: O(n), Calling thread immediately continues after offloading the work onto a worker thread.
Dequeue: O(1), Calling thread must wait if the queue is empty but active enqueues are present.
DequeueAsync: O(1), Calling thread immediately continues after offloading the work onto a worker thread.
Peek: O(1), Calling thread must wait if the queue is empty but active enqueues are present.

Usage:

Properties

/// <summary> /// The priority mode to set the priority queue. /// </summary> public PriorityType Mode { get; private set; } /// <summary> /// The number of values currently in the queue. /// </summary> public int Count /// <summary> /// The number of asynchronous operations currently scheduled. /// </summary> public int AsyncEnqueueOperations

Constructor

/// <summary> /// Creates a new concurrent priority queue. /// </summary> /// <param name="mode">The type of priority to use for the queue.</param> public ConcurrentPriorityQueue(PriorityType mode = PriorityType.Max)

Methods

/// <summary> /// Tries to add an entry to the priority queue. /// </summary> /// <param name="priority">A comparable value to be used as the priority.</param> /// <param name="value">The value to be stored into the queue.</param> /// <param name="allowDuplicates">Whether or not to allow adding if an entry with the same priority already exists.</param> /// <returns>true if entry was successfully added to the queue, otherwise false.</returns> /// <remarks>This method blocks until the enqueue operation has completed.</remarks> public bool TryEnqueue(P priority, V value, bool allowDuplicates = true) /// <summary> /// Asynchronously adds to the priority queue. /// </summary> /// <param name="priority">A comparable value to be used as the priority.</param> /// <param name="value">The value to be stored into the queue.</param> /// <param name="callback">The callback to invoke once the enqueue operation has completed.</param> /// <remarks>This method does not block.</remarks> public void TryEnqueueAsync(P priority, V value, Action<AsyncPriorityOperationResult>? callback = null) /// <summary> /// Asynchronously adds an entry to the priority queue. /// </summary> /// <param name="priority">A comparable value to be used as the priority.</param> /// <param name="value">The value to be stored into the queue.</param> /// <param name="allowDuplicates">Whether or not to allow adding if an entry with the same priority already exists.</param> /// <param name="callback">The callback to invoke once the enqueue operation has completed.</param> /// <remarks>This method does not block.</remarks> public void TryEnqueueAsync(P priority, V value, bool allowDuplicates, Action<AsyncPriorityOperationResult>? callback = null) /// <summary> /// Tries to retrieve and remove from the priority queue. /// </summary> /// <param name="value">The value which has been dequeued.</param> /// <returns>true if an entry has been successfully dequeued, otherwise false.</returns> /// <remarks>This method blocks until the dequeue operation has completed.</remarks> public bool TryDequeue(out V value) /// <summary> /// Asyncronously dequeues an entry from the priority queue. /// </summary> /// <param name="callback">The callback delegate to invoke after dequeuing has completed.</param> /// <remarks>This method does not block.</remarks> public void TryDequeueAsync(Action<AsyncPriorityOperationResult>? callback = null) /// <summary> /// Tries to retrieve without removing from the priority queue. /// </summary> /// <param name="value">The value at the beginning of the priority queue.</param> /// <returns>true if an entry has been successfully retrieved, otherwise false.</returns> /// <remarks>This method blocks until the peek operation has completed.</remarks> public bool TryPeek(out V? value) /// <summary> /// Blocks until all asynchronous enqueue opertions are completed. /// </summary> /// <remarks>This method blocks until there are no more active asynchronous enqueues</remarks> public void WaitForAsyncEnqueues(int millisecondsTimeout = 0) /// <summary> /// Clears the entries currently in the queue. /// </summary> /// <remarks>Asynchronous enqueues after this method will still be added.</remarks> public void Clear()