Что такое CompletableFuture и для чего он используется?

CompletableFuture — это расширение интерфейса Future, появившееся в Java 8, которое предоставляет мощный API для асинхронного программирования. В отличие от простого Future, который лишь позволяет проверить, завершена ли задача, и получить результат, CompletableFuture позволяет явно завершать вычисления, комбинировать несколько этапов обработки и обрабатывать исключения.

Основные возможности

• Асинхронное выполнение: Задачи можно запускать в фоновых потоках, используя пулы потоков.
• Цепочки вызовов: Методы thenApply, thenAccept, thenCompose позволяют строить последовательности операций, которые выполняются после завершения предыдущей.
• Комбинирование: Методы thenCombine, allOf, anyOf позволяют объединять результаты нескольких независимых асинхронных задач.
• Обработка исключений: Метод exceptionally позволяет предоставить fallback-значение в случае ошибки.

Пример использования

Рассмотрим простой пример, где мы асинхронно получаем данные, обрабатываем их и комбинируем с другим результатом.

import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;

public class CompletableFutureExample {
    public static void main(String[] args) throws ExecutionException, InterruptedException {
        // Асинхронно получаем имя пользователя
        CompletableFuture futureName = CompletableFuture.supplyAsync(() -> {
            try {
                Thread.sleep(1000); // Имитация долгой операции
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            return "Alice";
        });

        // Асинхронно получаем приветствие
        CompletableFuture futureGreeting = CompletableFuture.supplyAsync(() -> "Hello");

        // Комбинируем результаты: когда оба завершатся, объединяем строки
        CompletableFuture combinedFuture = futureGreeting.thenCombine(futureName, (greeting, name) -> greeting + ", " + name + "!");

        // Получаем итоговый результат (блокирующий вызов для примера)
        String result = combinedFuture.get();
        System.out.println(result); // Вывод: Hello, Alice!
    }
}

В этом примере supplyAsync запускает задачу асинхронно. Метод thenCombine ждёт завершения обоих Future и применяет функцию для объединения их результатов. В реальных приложениях вместо блокирующего get() часто используют callback-методы, такие как thenAccept, чтобы продолжить обработку без блокировки потока.

Где применяется

CompletableFuture широко используется в серверных приложениях на Java, особенно в микросервисных архитектурах, где необходимо выполнять несколько независимых запросов к внешним API или базам данных параллельно. Он также полезен в UI-приложениях для выполнения фоновых задач без "зависания" интерфейса. Многие современные фреймворки, такие как Spring, используют CompletableFuture для реактивных возможностей.

Вывод: CompletableFuture стоит применять, когда нужно повысить производительность приложения за счёт асинхронного выполнения задач, особенно при работе с вводом-выводом (например, сетевые запросы, чтение файлов) или при необходимости комбинировать результаты нескольких параллельных операций.