how to handle QUEUE of threads c#

Question

hi i want to build a simple program which does

  Parallel.ForEach(m_CustomerArr, customer =>
        {
            customer.OrderSomthing();
        });

when customer order something he query database, when his item run out of he contact to the supplier

      public bool takeOrder(Order o)
    {
            lock (s_QueueLocker)
            {
                OrderQueue.Enqueue(o);
            }
            //waits here to be signaled by the working thread of supplier 
            o.m_ManualResetEvent.WaitOne();**
        return true;
    }

there is only one supplier who holdes a queue who have a supplierthread:

   public void CreateThead()
    {
        Order currentOrder;
        while (true)
        {
            if (OrderQueue.Count != 0)
            {
                currentOrder = OrderQueue.Dequeue();
                DoOrder(currentOrder); 
            }
        }

    }
     private void DoOrder(Order currentOrder)
    {
        //update the db this function runes only in one thread 
        currentOrder.m_ManualResetEvent.Set();
        System.Threading.Thread.Sleep(5000);
    }

where m_ManualResetEvent is a member of customer whom is passed to every order in c'tor

   public class Order
{
    public ManualResetEvent m_ManualResetEvent;
    public string m_Query;
    public int m_Quntity;

    public Order(ManualResetEvent customerManualResetEvent, string query, int quntity)
    {
        m_ManualResetEvent = customerManualResetEvent;
        m_Query = query;
        m_Quntity = quntity;
    }

}

what would be a the best way to stop the thread on wait (in **) and signal him like mutex in c ? I am new to c# multi-threading and my concept is from Linux kernel so things might be easier in C# in a class somebody already built whom implement it...

so my question is ' is there a better design , better practice , better way to do the above ?

how to handle QUEUE of threads c#

Answers (1)

Related Questions