Fundamentos de los Pools de Hilos

Un pool de hilos es un patrón de arquitectura de concurrencia que administra un conjunto de hilos de trabajo reutilizables. En lugar de instanciar y destruir hilos para cada tarea individual, este mecanismo centraliza su ciclo de vida. Esto reduce drásticamente la sobrecarga del sistema operativo, mejora los tiempos de respuesta de la aplicación y previene el agotamiento de recursos provocado por una proliferación descontrolada de hilos.

Configuración de ThreadPoolExecutor

En el ecosistema de Java, la clase ThreadPoolExecutor es la implementación base. Su constructor permite un ajuste fino mediante los siguientes parámetros:

public ThreadPoolExecutor(
    int coreSize,
    int maxSize,
    long keepAlive,
    TimeUnit timeUnit,
    BlockingQueue<Runnable> taskQueue,
    ThreadFactory factory,
    RejectedExecutionHandler rejectionHandler
)

• coreSize (Hilos núcleo): Cantidad mínima de hilos que permanecen activos en el pool, incluso si no hay tareas pendientes. Garantiza la capacidad de procesamiento base.
• maxSize (Hilos máximos): Límite absoluto de hilos que el pool puede instanciar. Solo se crean hilos adicionales cuando la cola de tareas está completamente saturada.
• keepAlive y timeUnit: Define el tiempo máximo de inactividad que un hilo no esencial (por encima del núcleo) puede esperar antes de ser eliminado para liberar recursos.
• taskQueue (Cola de trabajo): Estructura que retiene las tareas antes de su ejecución. Las implementaciones típicas incluyen ArrayBlockingQueue (capacidad fija), LinkedBlockingQueue (capacidad ilimitada, con riesgo de desbordamiento de memoria), SynchronousQueue (entrega directa sin almacenamiento) y DelayQueue (para tareas con retardo).
• factory (Fábrica de hilos): Permite personalizar la creación de hilos, facilitando la asignación de nombres descriptivos y prioridades para simplificar la depuración en los logs.
• rejectionHandler (Política de rechazo): Estrategia que se ejecuta cuando tanto el pool como la cola han alcenzado su capacidad máxima. Las políticas nativas incluyen AbortPolicy (lanza una excepción), CallerRunsPolicy (ejecuta la tarea en el hilo que la envió), DiscardPolicy (descarta silenciosamente) y DiscardOldestPolicy (elimina la tarea más antigua en la cola).

Flujo de Ejecución de Tareas

El procesamiento de una nueva tarea sigue una lógica secuencial estricta:

1. Se evalúa si la cantidad de hilos activos es inferior al coreSize. Si es así, se crea un nuevo hilo núcleo para ejecutar la tarea.
2. Si el núcleo está lleno, la tarea se intenta insertar en la taskQueue.
3. Si la cola está saturada, se verifica si el total de hilos es menor que el maxSize. De haber espacio, se crea un hilo no esencial.
4. Si el límite máximo también se ha alcanzado, se invoca al rejectionHandler configurado.

Fábricas Predefinidas y sus Riesgos

La clase utilitaria Executors proporciona métodos rápidos para generar pools preconfigurados. Sin embargo, su uso en entornos de producción está fuertemente desaconsejado debido a configuraciones de cola y límites de hilos que pueden comprometer la estabilidad del sistema.

Pool de Tamaño Fijo

int workerCount = 5;
ExecutorService fixedPool = Executors.newFixedThreadPool(workerCount);

Riesgo: Utiliza una LinkedBlockingQueue sin límites. Una alta tasa de producción de tareas puede provocar un OutOfMemoryError.

Pool de Hilo Único

ExecutorService singleWorker = Executors.newSingleThreadExecutor();

Riesgo: Garantiza la ejecución secuencial estricta, pero comparte el mismo riesgo de desbordamiento de memoria por su cola ilimitada.

Pool Cacheado

ExecutorService cachedPool = Executors.newCachedThreadPool();

Riesgo: Emplea una SynchronousQueue y no tiene límite máximo de hilos (Integer.MAX_VALUE). Bajo cargas pesadas, puede crear miles de hilos y saturar la CPU.

Pool Programado

ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(3);

Uso: Diseñado específicamente para la ejecución retardada o periódica de tareas.

Comparativa de Estructuras Map: Hashtable vs HashMap vs ConcurrentHashMap