Асинхронность и параллелизм — не одно и то же
Асинхронная программа может начать операцию и продолжить другую работу, не ожидая завершения первой. Параллелизм означает физическое выполнение нескольких вычислений одновременно на разных ядрах. Для сетевого ожидания асинхронность особенно полезна, потому что процессор не обязан простаивать. Для тяжёлых вычислений уже важны число ядер и размер пула потоков.
Пул потоков лучше бесконтрольного создания Thread
ExecutorService позволяет управлять ограниченным числом рабочих потоков и очередью задач. Это защищает приложение от ситуации, когда тысячи запросов создают тысячи потоков и съедают память. Размер пула выбирают под тип нагрузки: вычислительная и преимущественно ожидающая работа имеют разные требования. После использования пул нужно корректно завершать.
CompletableFuture строит цепочку результата
CompletableFuture позволяет описать, что делать после завершения операции, не вызывая блокирующий get на каждом шаге. Можно преобразовать результат, объединить две независимые операции или обработать ошибку. Важно понимать, где выполняется каждый этап и какой executor используется, иначе тяжёлая задача неожиданно попадёт в общий пул и начнёт мешать другим операциям.
Общие изменяемые данные остаются главным риском
Если несколько задач одновременно меняют одну коллекцию или объект, возможны гонки. Асинхронный стиль не отменяет правил потокобезопасности. Лучше минимизировать совместное изменяемое состояние, использовать неизменяемые данные или подходящие конкурентные структуры. Ошибки также нужно обрабатывать явно: потерянное исключение в фоновой задаче иногда выглядит как тихо исчезнувшая функция.
Попробуйте на практике
Собрать цепочку из двух независимых асинхронных операций и одного объединения.
- Создайте две функции, которые возвращают разные значения с искусственной задержкой.
- Запустите их через CompletableFuture независимо друг от друга.
- Объедините результаты через подходящую комбинацию без последовательного блокирующего ожидания.
- Добавьте обработку исключения для одной операции.
- Замерьте время и сравните с последовательным вызовом.
Как проверить результат. Упражнение выполнено, если две независимые задержки перекрываются по времени, исключение обрабатывается явно, а итоговая логика не использует лишнее блокирование.
Частые вопросы
CompletableFuture всегда создаёт новый поток?
Нет. Выполнение зависит от метода и выбранного executor. Некоторые этапы могут выполняться в потоке, завершившем предыдущую стадию.
Асинхронность ускоряет любые вычисления?
Нет. Она особенно полезна для ожидания. Для CPU-нагрузки важны параллелизм, число ядер и стоимость переключений.
Почему не стоит делать get сразу после запуска?
Потому что немедленный блокирующий get превращает асинхронный запуск почти в обычный последовательный код и теряет часть преимущества.
Самостоятельный разбор темы. Содержание конкретной обучающей программы здесь не представлено.