Search code examples
c#.netmultithreadingpriority-queue.net-6.0

Is .NET 6 PriorityQueue thread-safe?


.NET 6 now has PriorityQueue<TElement,TPriority> which is very useful. The document is not very clear yet (granted at the time of the question the documentation is still for RC1) if it is thread-safe or not. Two things:

  • It resides in System.Collections.Generic and there doesn't seem to be an equivalent in System.Collections.Concurrent.

  • It does have method named TryDequeue and TryPeek. Granted they probably are just methods that do not throw exception when the queue is empty but it does give an impression of the concurrent collections.

Can I use it for multithreaded environment without wrapping/locking (for example in an ASP.NET Core website)? Any concurrent equivalent that I am not aware of (I try not to use 3rd-party package if possible)?


Solution

  • With a look at the source code for PriorityQueue.Enqueue, for instance, it is immediately apparent that the code is not thread-safe:

    public void Enqueue(TElement element, TPriority priority)
    {
        // Virtually add the node at the end of the underlying array.
        // Note that the node being enqueued does not need to be physically placed
        // there at this point, as such an assignment would be redundant.
    
        int currentSize = _size++; // <-- BOOM