Зачем нужен CompletableFuture в Java?

CompletableFuture используется для асинхронного выполнения задач и композиции асинхронных операций. Он представляет собой результат асинхронной операции, который может быть завершен в будущем.

Основные преимущества и причины использования:

• Асинхронное выполнение: Позволяет выполнять задачи в фоновом режиме, не блокируя основной поток.
• Композиция асинхронных операций: Дает возможность связывать несколько асинхронных задач, определяя, как они должны выполняться последовательно или параллельно, и обрабатывать их результаты.
• Обработка исключений: Предоставляет механизмы для обработки ошибок в асинхронно выполняемых задачах.
• Гибкость: Поддержка различных методов для обработки результата (например, применение функции, выполнение следующей задачи) и определения потоков выполнения.

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

1. Выполнение нескольких независимых задач параллельно и ожидание их завершения:

   // Пример параллельного выполнения двух задач
   CompletableFuture<String> future1 = CompletableFuture.supplyAsync(() -> {
       // Долгая операция 1
       return "Результат 1";
   });
   
   CompletableFuture<String> future2 = CompletableFuture.supplyAsync(() -> {
       // Долгая операция 2
       return "Результат 2";
   });
   
   CompletableFuture<Void> combinedFuture = CompletableFuture.allOf(future1, future2);
   
   combinedFuture.join(); // Ожидание завершения обеих задач
   

2. Выполнение последовательных асинхронных операций:

   // Пример последовательного выполнения задач
   CompletableFuture<String> initialFuture = CompletableFuture.supplyAsync(() -> "Начальное значение");
   
   CompletableFuture<Integer> transformedFuture = initialFuture.thenApplyAsync(result -> {
       // Преобразование результата
       return result.length();
   });
   
   transformedFuture.thenAccept(length -> {
       System.out.println("Длина строки: " + length);
   });
   

3. Обработка исключений:

   // Пример обработки исключения
   CompletableFuture<String> errorFuture = CompletableFuture.supplyAsync(() -> {
       if (true) {
           throw new RuntimeException("Произошла ошибка");
       }
       return "Успех";
   }).exceptionally(ex -> {
       System.err.println("Обработка ошибки: " + ex.getMessage());
       return "Обработанная ошибка"; // Возвращение запасного значения
   });
   
   System.out.println(errorFuture.join());