Problema de Productor/consumidor

• 0
  Darwin Mar
  28/10/2018 02:55
  La cuestion es que deseo hacer que cada producto sea consumido o leido por todos los consumidores y que no pase al segundo producto hasta que todos lo hallan leido, por ejemplo producto 1 lo lee consumidor 1,2,3...n, pasa a producto 2 y lo lee consumidor 1,2,3...n y asi sucesivamente, les muestro la parte de codigo que tengo.
  public class Test
  {
  static ProducerConsumer queue;
  
  static void Main()
  {
        queue = new ProducerConsumer();
        new Thread(new ThreadStart(ConsumerJob)).Start();
  
        Random rng = new Random(0);
        for (int i = 0; i < 10; i++)
        {
             Console.WriteLine("Producing {0}", i);
             queue.Produce(i);
             Thread.Sleep(rng.Next(1000));
        }
        Console.ReadKey();
  }
  
  static void ConsumerJob()
  {
       
        Random rng = new Random(1);
       
        for (int i = 0; i < 10; i++)
        {
             object o = queue.Consume();
             Console.WriteLine("\t\t\t\tConsuming {0}", o);
             Thread.Sleep(rng.Next(1000));
        }
  }
  }
  
  public class ProducerConsumer
  {
  readonly object listLock = new object();
  Queue queue = new Queue();
  
  public void Produce(object o)
  {
        lock (listLock)
        {
             queue.Enqueue(o);
  
            
             Monitor.Pulse(listLock);
        }
  }
  
  public object Consume()
  {
        lock (listLock)
        {
            
             while (queue.Count == 0)
             {
            
                  Monitor.Wait(listLock);
             }
             return queue.Dequeue();
        }
       
  }
  }
  

  Reply

  Responder

  You have to register to coment Register

  Publicar comentario
•  0
  Darwin Mar
  28/10/2018 02:56
  Espero su resp.

  Reply