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

Для точного контроля нужно отказаться от удобных фабрик.

Почему Executors недостаточен

Executors.newFixedThreadPool():

• использует неограниченную очередь

• может привести к OOM

Явная настройка пула

ThreadPoolExecutor executor =
    new ThreadPoolExecutor(
        4,
        8,
        30, TimeUnit.SECONDS,
        new ArrayBlockingQueue<>(50)
    );

Здесь контролируются:

• количество потоков

• размер очереди

• поведение при простое

Стратегии отказа

При переполнении очереди применяются:

• AbortPolicy

• CallerRunsPolicy

• DiscardPolicy

• DiscardOldestPolicy

Выбор стратегии влияет на устойчивость системы.

Мониторинг

Важно:

• отслеживать размер очереди

• контролировать время выполнения задач

• логировать отклонения

Вывод

Полный контроль очереди задач возможен только при использовании ThreadPoolExecutor и ограниченных очередей.