ExecutorService и типы пулов потоков
Создавайте фиксированные, кэшируемые, однопоточные и планируемые пулы потоков и определяйте, когда использовать каждый из них.
«ExecutorService и типы пулов потоков» — бесплатный урок Java Academy на CoddyKit. Это урок 1 из 4. Ты можешь прочитать весь урок бесплатно ниже — а потом практиковать его прямо в браузере с встроенным редактором кода и ИИ-репетитором 24/7. Это часть пути обучения Java Academy, и твой прогресс синхронизируется между веб-версией и приложением CoddyKit. Курс Java Academy содержит 4 уроков всего.
Зачем нужны пулы потоков
Создавать новый Thread для каждой задачи дорого: создание и уничтожение потока требуют дополнительных ресурсов. Пул потоков повторно использует фиксированный набор потоков для выполнения множества задач, уменьшая накладные расходы и контролируя потребление ресурсов.
import java.util.concurrent.*;
// Bad practice: new thread per task
new Thread(() -> System.out.println("task")).start();
// Better: reuse threads from a pool
ExecutorService pool = Executors.newFixedThreadPool(4);
pool.submit(() -> System.out.println("task from pool"));
pool.shutdown();newFixedThreadPool
Создаёт пул ровно из N потоков. Дополнительные задачи становятся в очередь, пока поток не освободится. Подходит, когда известен необходимый уровень параллелизма.
ExecutorService pool = Executors.newFixedThreadPool(4);
for (int i = 0; i < 10; i++) {
final int taskId = i;
pool.submit(() -> {
System.out.println("Task " + taskId + " on " + Thread.currentThread().getName());
});
}
pool.shutdown();
pool.awaitTermination(10, TimeUnit.SECONDS);newCachedThreadPool
Создаёт потоки по мере необходимости и повторно использует простаивающие потоки. Потоки, бездействующие в течение 60 секунд, завершаются. Подходит для множества краткоживущих задач, но опасен для долгих или неограниченных задач: память может закончиться.
ExecutorService cached = Executors.newCachedThreadPool();
for (int i = 0; i < 100; i++) {
cached.submit(() -> {
// quick task
double result = Math.sqrt(Math.random());
});
}
cached.shutdown();newSingleThreadExecutor
Пул ровно с одним потоком. Задачи выполняются последовательно в порядке отправки. Подходит для последовательного доступа к общему ресурсу.
ExecutorService single = Executors.newSingleThreadExecutor();
single.submit(() -> System.out.println("Task 1"));
single.submit(() -> System.out.println("Task 2"));
single.submit(() -> System.out.println("Task 3"));
// Always prints: Task 1, Task 2, Task 3 (sequential)
single.shutdown();newScheduledThreadPool
Поддерживает запланированные и периодически повторяющиеся задачи. Используйте его для опроса, повторных попыток и фонового обслуживания.
ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(2);
// One-shot delay
scheduler.schedule(() -> System.out.println("Delayed!"),
3, TimeUnit.SECONDS);
// Fixed rate (every 2 seconds)
scheduler.scheduleAtFixedRate(
() -> System.out.println("Tick"),
0, 2, TimeUnit.SECONDS);
// Run later: scheduler.shutdown();VirtualThreadExecutor (Java 21+)
В Java 21 появились виртуальные потоки — лёгкие и дешёвые в создании. Используйте Executors.newVirtualThreadPerTaskExecutor() для рабочих нагрузок с интенсивными операциями ввода-вывода:
// Java 21+
try (var exec = Executors.newVirtualThreadPerTaskExecutor()) {
for (int i = 0; i < 10_000; i++) {
final int id = i;
exec.submit(() -> {
Thread.sleep(100); // blocks without tying up OS thread
System.out.println("vthread " + id);
});
}
} // auto-shutdownВыбор подходящего пула
Рекомендации:
- Задачи с высокой нагрузкой на CPU: фиксированный пул, где N равно числу ядер CPU
- Задачи с интенсивным вводом-выводом: кэшируемый пул или виртуальные потоки
- Последовательные задачи: исполнитель с одним потоком
- Запланированные и периодические задачи: пул планировщика
int cores = Runtime.getRuntime().availableProcessors();
ExecutorService cpuPool = Executors.newFixedThreadPool(cores);
System.out.println("Pool size: " + cores);Настраиваемый ThreadPoolExecutor
Для детального управления создайте ThreadPoolExecutor напрямую:
ThreadPoolExecutor tpe = new ThreadPoolExecutor(
2, // corePoolSize
10, // maximumPoolSize
60L, // keepAliveTime
TimeUnit.SECONDS,
new LinkedBlockingQueue<>(100), // work queue
Executors.defaultThreadFactory(),
new ThreadPoolExecutor.CallerRunsPolicy() // rejection policy
);
tpe.submit(() -> System.out.println("Custom pool task"));
tpe.shutdown();Корректное завершение
Всегда завершайте работу ExecutorService, чтобы освободить потоки. shutdown() прекращает приём новых задач, но завершает задачи, уже находящиеся в очереди. shutdownNow() пытается отменить выполняющиеся задачи.
ExecutorService pool = Executors.newFixedThreadPool(4);
// ... submit tasks ...
pool.shutdown(); // no new tasks
try {
if (!pool.awaitTermination(30, TimeUnit.SECONDS)) {
pool.shutdownNow(); // force cancel
}
} catch (InterruptedException e) {
pool.shutdownNow();
Thread.currentThread().interrupt();
}ExecutorService как AutoCloseable (Java 19+)
В Java 19+ ExecutorService реализует AutoCloseable. Используйте конструкцию try-with-resources для автоматического завершения работы:
// Java 19+ (preview), Java 21 stable
try (ExecutorService pool = Executors.newFixedThreadPool(4)) {
pool.submit(() -> System.out.println("task"));
} // pool.close() called: waits for tasks then shuts downПолитики отклонения
Когда пул переполнен (все потоки заняты, очередь заполнена), политика отклонения обрабатывает лишние задачи:
- AbortPolicy (по умолчанию): выбрасывает
RejectedExecutionException - CallerRunsPolicy: вызывающий поток выполняет задачу
- DiscardPolicy: молча отбрасывает задачу
- DiscardOldestPolicy: отбрасывает самую старую задачу в очереди
Быстрая проверка
У Вас есть задача с высокой нагрузкой на CPU, выполняющая сложные вычисления. Сколько потоков должен содержать фиксированный пул?
Итоги: ExecutorService и пулы потоков
Основные выводы:
- Фиксированный пул: фиксированное число N потоков; дополнительные задачи помещаются в очередь
- Кэшируемый пул: увеличивается по мере необходимости; простаивающие потоки завершаются через 60 секунд
- Один поток: гарантируется последовательный порядок выполнения
- Планировщик: задачи с задержкой и периодические задачи
- Всегда вызывайте
shutdown(); используйтеawaitTermination()для корректного завершения
Часто задаваемые вопросы
Урок «ExecutorService и типы пулов потоков» бесплатный?
Да — полный текст урока «ExecutorService и типы пулов потоков» бесплатно доступен здесь в веб-версии. Чтобы практиковать его интерактивно (встроенный редактор кода и ИИ-репетитор 24/7) и разблокировать остальной курс Java Academy, подпишись на CoddyKit PRO. Курс Java Academy содержит 4 уроков всего.
Чему я научусь в уроке «ExecutorService и типы пулов потоков»?
Создавайте фиксированные, кэшируемые, однопоточные и планируемые пулы потоков и определяйте, когда использовать каждый из них. Ты практикуешь Java Academy с помощью реального кода, который запускаешь прямо в браузере, и ИИ-репетитор 24/7 отвечает на твои вопросы во время урока.
Нужен ли мне опыт, чтобы начать Java Academy?
Предыдущий опыт не требуется. Java Academy на CoddyKit структурирован для всех уровней — от новичков до продвинутых, поэтому ты можешь начать отсюда или с самого начала и учиться в своем темпе. Это урок 1 из 4.
Сколько времени занимает урок «ExecutorService и типы пулов потоков»?
Большинство уроков CoddyKit занимают около 5–10 минут. Каждый из них компактный и интерактивный, поэтому ты постоянно делаешь прогресс и продолжаешь с того же места в веб-версии и приложении.
Можно ли писать и запускать код в этом уроке Java Academy?
Да. Каждый урок Java Academy включает встроенный редактор кода, поэтому ты пишешь и запускаешь реальный код прямо в браузере и получаешь моментальную обратную связь от AI — локальная установка не требуется.
Все уроки этого курса
- ExecutorService и типы пулов потоков
- Отправка задач: Runnable и Callable
- Future и обработка ошибок
- ScheduledExecutorService для повторяющихся задач