How do I dispatch my threads with a priority

See more:

threads

C#5.0

Hi,

I have a message queue that I need to parse. Some messages are urgent and need to be processed first.

I also need to use threading. Processing these messages in a linear fashion is far too slow.

At peak times I could have a backlog of thousands.

I tried using a ThreadPool. The speed was significantly improved but I could not (or don't know how to) process priority messages first.

I tried using a Dispatcher, but none of the threads actually run:

public delegate void NextPrimeDelegate();
private Dispatcher _dispatcher = Dispatcher.CurrentDispatcher;

public void ParseMessageQueue()
{

    //Projections message is a db reference to the instance.
    WorkflowDataAccess.Projections.Message message;

    //Get next message from the queue.  If the queue is empty then it will wait this thread until one arrives.  All these messages have 'read'=true
    while ((message = _messageQueue.Next) != null)
    {
    //Debug message
    Logs.Log(string.Format(@"3. Message Id: {0}", message.Id));

        //Get a loop safe version of m
        var m = message;
        //Queue the method and item

        var next = new NextPrimeDelegate(() => { CallBack(m); });
        DispatcherPriority dispatcherPriority;
        switch (m.Urgency)
        {
            case 0:
                dispatcherPriority=DispatcherPriority.Normal;
                break;
            default:
                dispatcherPriority = DispatcherPriority.Send;
                break;
        }

        //Callback does not get run >_<
        _dispatcher.BeginInvoke(dispatcherPriority, next);
    
        //threads without priority
        //ThreadPool.QueueUserWorkItem(CallBack, m,);

        //Linear
        //CallBack(m);
    }
}

Maybe I'm doing it wrong?

Any suggestions how I can improve the performance and prioritize the urgent messages?

Thanks ^_^
Andy