Как контролировать размер очереди задач в ExecutorService?

Question

Размер очереди контролируется через конкретную реализацию BlockingQueue.
Стандартные фабрики Executors этого не позволяют.
Нужно использовать ThreadPoolExecutor.
Ограниченная очередь предотвращает перегрузку памяти.
Также важно настроить стратегию обработки переполнения.

YeaHub · Accepted Answer

Для точного контроля нужно отказаться от удобных фабрик.Почему Executors недостаточенExecutors.newFixedThreadPool():использует неограниченную очередьможет привести к OOMЯвная настройка пулаThreadPoolExecutor executor =
    new ThreadPoolExecutor(
        4,
        8,
        30, TimeUnit.SECONDS,
        new ArrayBlockingQueue<>(50)
    );
Здесь контролируются:количество потоковразмер очередиповедение при простоеСтратегии отказаПри переполнении очереди применяются:AbortPolicyCallerRunsPolicyDiscardPolicyDiscardOldestPolicyВыбор стратегии влияет на устойчивость системы.МониторингВажно:отслеживать размер очередиконтролировать время выполнения задачлогировать отклоненияВыводПолный контроль очереди задач возможен только при использовании ThreadPoolExecutor и ограниченных очередей.