1  class Repositorio

    2     {

    3         public ArrayList listarecolectora = new ArrayList();

    4         public ArrayList listaescritora = new ArrayList();

    5         public int PausaProductor = 5;

    6         public int PausaConsumidor = 30;

    7     }

    1     /// <summary>

    2     /// Clase Productor

    3     /// </summary>

    4     class Productor

    5     {

    6         #region Variables

    7 

    8         Random random = new System.Random();

    9         Repositorio repositorio;

   10         public bool FinalizarProceso = false;

   11         //Maximo número aleatorio generador por el productor

   12         const int MaximoNumeroGenerado = 100; 

   13 

   14         int iteracion;

   15         public int Iteracion

   16         {

   17             get { return iteracion; }

   18             set { iteracion = value; }

   19         }

   20 

   21         #endregion

   22 

   23         #region Constructor

   24 

   25         public Productor(Repositorio repositorio)

   26         {

   27             this.repositorio = repositorio;

   28             iteracion = 0;

   29         }

   30 

   31         #endregion

   32 

   33         #region Metodos

   34 

   35         public void GenerarValores()

   36         {

   37             while (!FinalizarProceso)

   38             {

   39                 //Bloque lista y produzo elementos con una pausa de ValorPausa

   40                 lock (repositorio.listaescritora)

   41                 {

   42                     iteracion++;

   43                     int valor = random.Next(MaximoNumeroGenerado);

   44                     Console.WriteLine(String.Format("<br>Iteración: {0} - Produzco valor: {1}", iteracion, valor));

   45                     repositorio.listaescritora.Add(valor);

   46                 }

   47                 Thread.Sleep(this.repositorio.PausaProductor);

   48             }

   49         }

   50 

   51         public void DetenerProceso()

   52         {

   53             FinalizarProceso = true;

   54         }

   55 

   56         #endregion

   57 

   58     }

    1     /// <summary>

    2     /// Clase Consumidor

    3     /// </summary>

    4     class Consumidor

    5     {

    6         #region Variables

    7 

    8         Repositorio repositorio;

    9         String Nombre;

   10 

   11         public bool EnProceso = true;

   12         public bool FinalizarProceso = false;

   13 

   14         int iteracion;

   15         public int Iteracion

   16         {

   17             get {return iteracion;}

   18             set {iteracion = value;}

   19         }

   20 

   21         #endregion

   22 

   23         #region Constructor

   24 

   25         public Consumidor(Repositorio repositorio, String Nombre)

   26         {

   27             this.repositorio = repositorio;

   28             this.Nombre = Nombre;

   29             iteracion = 0;

   30         }

   31 

   32         #endregion

   33 

   34         #region Metodos

   35 

   36         public void ConsumirValor()

   37         {

   38             while (EnProceso)

   39             {

   40                 Thread.Sleep(this.repositorio.PausaConsumidor);

   41                 lock (repositorio.listaescritora)

   42                 {

   43                     if (repositorio.listaescritora.Count > 0)

   44                     {

   45                         //Consumo primero elemento de la lista y desbloque recurso

   46                         iteracion++;

   47                         Console.WriteLine(String.Format("{0} consume valor: {1} - Iteración: {2}", Nombre, repositorio.listaescritora[0], iteracion));

   48                         repositorio.listarecolectora.Add(repositorio.listaescritora[0]);

   49                         repositorio.listaescritora.RemoveAt(0);

   50                     }

   51 

   52                     if (FinalizarProceso)

   53                     {

   54                         if (repositorio.listaescritora.Count == 0) EnProceso = false;

   55                     }

   56                 }

   57             }

   58         }

   59 

   60         public void DetenerProceso()

   61         {

   62             FinalizarProceso = true;

   63         }

   64 

   65         #endregion

   66 

   67 

   68 

   69     }

    1     static class Inicio
    2     {

    3         //Tiempo utilizado para que los consumidores consuman los elementos restantes

    4         const int Pausa = 300;

    5 

    6 

    7         static void Main()

    8         {

    9             Comienzo();

   10         }

   11 

   12         public static void Comienzo()

   13         {

   14 

   15             Repositorio repositorio = new Repositorio();

   16 

   17             Productor productor = new Productor(repositorio);

   18 

   19             ThreadStart threadstartproductor = new ThreadStart(productor.GenerarValores);

   20             Thread threadproductor = new Thread(threadstartproductor);

   21 

   22             Consumidor consumidor_1 = new Consumidor(repositorio, "Consumidor_1");

   23             Consumidor consumidor_2 = new Consumidor(repositorio, "Consumidor_2");

   24 

   25             ThreadStart threadstartconsumidor_1 = new ThreadStart(consumidor_1.ConsumirValor);

   26             Thread threadconsumidor_1 = new Thread(threadstartconsumidor_1);

   27 

   28             ThreadStart threadstartconsumidor_2 = new ThreadStart(consumidor_2.ConsumirValor);

   29             Thread threadconsumidor_2 = new Thread(threadstartconsumidor_2);

   30 

   31             threadconsumidor_1.Start();

   32             threadconsumidor_2.Start();

   33 

   34             threadproductor.Start();

   35 

   36             Thread.Sleep(Pausa);

   37 

   38             productor.DetenerProceso();

   39             Console.WriteLine("<br>El productor recibe señal de terminar el proceso");

   40 

   41             consumidor_1.DetenerProceso();

   42             Console.WriteLine("<br>El consumidor_1 recibe señal de terminar el procesos");

   43 

   44             consumidor_2.DetenerProceso();

   45             Console.WriteLine("<br>El consumidor_2 recibe señal de terminar el procesos");

   46 

   47             Console.WriteLine(String.Format("<br>Elementos pendientes en repositorio: {0}", repositorio.listaescritora.Count));

   48 

   49             Console.WriteLine(String.Format("<br>Elementos consumidos Consumidor_1: {0} - Consumidor_2: {1}", consumidor_1.Iteracion, consumidor_2.Iteracion));

   50             Console.WriteLine(String.Format("<br>Total elementos producidos: {0}- Total elementos consumidos: {1}", productor.Iteracion, repositorio.listarecolectora.Count));

   51 

   52         }

   53     }