AccesoBaseDatosConSemaphoreSlim.cs

using System;
using System.Threading;

namespace Recetas.Multithreading.R0203
{
    public sealed class AccesoBaseDatosConSemaphoreSlim
    {
        // Creación de instancia de `SemaphoreSlim` para controlar el
        // límite de threads = 4:
        public static SemaphoreSlim _ss = new SemaphoreSlim(4);

        public static void Main()
        {
            Console.Title = "=== Demostración Uso SemaphoreSlim ===";
            Console.WriteLine();

            // Creación de 6 threads:
            for (int i = 1; i <= 6; ++i)
            {
                string nombreThread = String.Format("T{0}", i.ToString());

                int tiempoEspera = 2 + 2 * i;

                Thread nuevoThread = new Thread( () => AccederBaseDatos(nombreThread, tiempoEspera));

                // Inicio de ejecución de thread:
                nuevoThread.Start();
            }

            Console.WriteLine();
        }

        // Método que simula el control del acceso concurrente de threads
        // a una base de datos:
        public static void AccederBaseDatos(string nombreThread, int segundos)
        {
            Console.WriteLine ("Thread `{0}` debe espear para acceder a la base de datos.", nombreThread);
            _ss.Wait();

            Console.WriteLine ("Thread `{0}` tiene ahora acceso a la base de datos.", nombreThread);

            // Simula operaciones transaccionales o de consulta sobre la base de datos:
            Thread.Sleep(TimeSpan.FromSeconds(segundos));

            Console.WriteLine("Thread `{0}` ha finalizado su ejecución", nombreThread);

            // Continua la ejecución:
            _ss.Release();
        }
    }
}