Geek Answers Handbook

Buffered observable priority stream priority?

I am writing a program in which one thread needs to push elements into a queue, and one or more threads remove elements from the queue and process them. To avoid running out of memory, I would like the producer thread to sleep when the queue is full. Some elements have higher priority than others, so I would like them to be processed first. If the elements have the same priority, I would like the first to be added first for processing.

I want to display the 100 best elements or so in a WPF DataGrid, so the UI thread should also be facing it. It would be nice if he could notify the user interface thread that there is an update, i.e. Implements IObservable.

Is there a container class that will do all this?

For bonus points, I am sure that the entire queue should not be blocked both at the entrance to the queue and in the queue.

The .NET 4 implementations are fine.

+5
source share
3 answers

You are out of luck looking for a container - you have to implement it yourself. Be careful with priorities - sorting is slow. What I am doing is that I have a queue class that itself uses several arrays (one for priority - encoded low, medium, high). So I never sort. Avoid locks if you can (presumably with multiple cores) and upgrade to Spinlocks (.NET 4.0), they are faster / carry less overhead in a queue script.

+3

.NET 4, , , QueuedTaskScheduler. , , .

+2

, , ConcurrentQueue<T> , TomTom. , , , . , : . TryDequeue :

public bool TryDequeue(out T item)
{
    return _highItems.TryDequeue(out item) || _lowItems.TryDequeue(out item);
}

, , , .

+2

More articles:


All Articles