SincronizacionConsola.cs

using System;
using System.Threading;

namespace Recetas.CSharp.Cap04.R0410
{
    public sealed class SincronizacionConsola
    {
        // Determina el estado de ejecución de un thread:
        private static bool terminarThread = false;

        // Muestra mensajes de información acerca del estado
        // de ejecución de un thread:
        private static void Rastrear(string mensaje)
        {
            Console.WriteLine ("[{0,3}] - {1} : {2}",
                Thread.CurrentThread.ManagedThreadId,
                DateTime.Now.ToString("HH:mm:ss.ffff"),
                mensaje
            );
        }

        // Método a encapsular por diferentes threads y que
        // contiene una región crítica protegida por un
        // objeto Semaphore:
        private static void MostrarMensajeEnConsola()
        {
            // Se apropia de un instancia Semaphore con nombre
            // 'EjemploSemaphore':
            using (Semaphore semaforo = Semaphore.OpenExisting ("EjemploSemaphore"))
            {
                Rastrear("Inicio ejecución de thread.");

                while (!terminarThread)
                {
                    // Apoderamiento del semaforo:
                    semaforo.WaitOne();

                    Rastrear("Apoderamiento del Semaphore.");

                    Thread.Sleep(1000);

                    Rastrear ("Liberación del Semaphore.");

                    semaforo.Release();

                    // Pausa para dar la oportunidad de que otro
                    // thread se apodere del semaforo:
                    Thread.Sleep (100);
                }

                Rastrear ("A punto de finalizar un thread.");
            }
        }

        public static void Main()
        {
            Console.Title = "Demostración uso de Sincronización con Semaphore";
            Console.WriteLine ();

            // Creación de una instancia de Semaphore llamada `EjemploSemaphore`:
            using (Semaphore semaforo = new Semaphore (2, 2, "EjemploSemaphore"))
            {
                Rastrear ("Inicio de ejecución de threads. Presione Enter para finalizar.");

                // Creación de 3 threads:
                Thread t1 = new Thread (MostrarMensajeEnConsola);
                Thread t2 = new Thread (MostrarMensajeEnConsola);
                Thread t3 = new Thread (MostrarMensajeEnConsola);

                t1.Start();
                t2.Start();
                t3.Start();

                // Para finalizar se debe presionar Enter:
                Console.ReadLine ();

                // Finaliza los threads asociados con el método `MostrarMensajeEnConsola`,
                // y espera a que se completan antes de deshechar la instancia Semaphore:
                terminarThread = true;
                t1.Join(5000);
                t2.Join(5000);
                t3.Join(5000);
            }
        }
    }
}