Перейти на PRO

Приведи пример технологии или концепции, которую ты недавно изучил.

Тип вопроса: Софт-скиллы Вероятность: 10% Категория: Java Разработчик

Ответ

Пример: Глубокое изучение CompletableFuture в Java для асинхронного и неблокирующего программирования.

Что было изучено:

  • Комбинирование асинхронных задач без блокирующего ожидания.
  • Обработка исключений в цепочках вызовов.
  • Запуск задач с пользовательским ExecutorService для контроля над потоками.

Практический пример — параллельное выполнение и комбинирование результатов:

import java.util.concurrent.CompletableFuture;
import java.util.concurrent.Executors;

// Асинхронно получаем данные из двух независимых источников
CompletableFuture<Integer> fetchUserScore = CompletableFuture
        .supplyAsync(() -> userService.calculateScore(userId));

CompletableFuture<Integer> fetchProductRating = CompletableFuture
        .supplyAsync(() -> productService.getAverageRating(productId),
                     Executors.newFixedThreadPool(2)); // Кастомный пул

// Комбинируем результаты, когда оба future завершатся
CompletableFuture<Double> combinedResult = fetchUserScore
        .thenCombine(fetchProductRating, (score, rating) -> {
            // Логика объединения данных
            return score * 0.7 + rating * 0.3;
        });

// Обрабатываем результат или исключение
combinedResult
    .thenAccept(finalScore -> System.out.println("Final score: " + finalScore))
    .exceptionally(ex -> {
        System.err.println("Calculation failed: " + ex.getMessage());
        return null;
    });

Ключевые преимущества:

  1. Производительность: Параллельное выполнение независимых IO-операций.
  2. Читаемость: Четкая цепочка вызовов вместо "callback hell".
  3. Гибкость: Методы allOf(), anyOf(), handle(), thenCompose() для сложных сценариев.

Ответ 18+ 🔞

Да ты посмотри, что за хуйня творится в асинхронном мире! Сидишь ты такой, пишешь код, а он, сука, блокируется и ждёт, пока какая-нибудь удалённая служба ответит, как будто в очереди за сметаной в совке. Ну нихуя себе, так жить нельзя!

Вот взял я на днях этот ваш CompletableFuture и разобрался, как он, блядь, работает. Оказалось, штука охуенная, если понять, куда что впендюрить.

Что я там выяснил, блядь:

  • Склеивать задачи можно так, чтобы одна за другой цеплялась, и всё это без тупого ожидания, типа get(), который всё замораживает. Просто красота, ёпта!
  • Исключения ловить — отдельная песня. Раньше всё в try-catch оборачивал, а тут можно в самом конце цепочки прицепить exceptionally и всё, пиздец, обработано. Удобно, блядь.
  • Потоками управлять — вообще сказка. Не хочешь в общем пуле — хуяк свой собственный ExecutorService и впердоливаешь туда задачи. Контроль полный, как в хорошем борделе.

Вот смотри, как я это применил на практике, чтобы два запроса параллельно гонять:

import java.util.concurrent.CompletableFuture;
import java.util.concurrent.Executors;

// Один фьюч — тащит рейтинг пользователя, типа какой он молодец
CompletableFuture<Integer> fetchUserScore = CompletableFuture
        .supplyAsync(() -> userService.calculateScore(userId));

// Второй — тащит среднюю оценку товара. И чтоб не мешались друг другу, кидаем в отдельный маленький пул
CompletableFuture<Integer> fetchProductRating = CompletableFuture
        .supplyAsync(() -> productService.getAverageRating(productId),
                     Executors.newFixedThreadPool(2)); // Вот он, кастомный пул на два потока!

// А теперь самое интересное: ждём, когда оба этих дела хуёвых завершатся, и результаты скрещиваем
CompletableFuture<Double> combinedResult = fetchUserScore
        .thenCombine(fetchProductRating, (score, rating) -> {
            // Тут наша хитрая математика: 70% веса у пользователя, 30% у товара
            return score * 0.7 + rating * 0.3;
        });

// И что делаем с итогом? Правильно, либо выводим, либо материмся, если всё сломалось
combinedResult
    .thenAccept(finalScore -> System.out.println("Итоговый скор: " + finalScore))
    .exceptionally(ex -> {
        System.err.println("Всё накрылось медным тазом, причина: " + ex.getMessage());
        return null;
    });

И в чём, блядь, кайф-то?

  1. Скорость, ёбана! Две долгие операции не ждут друг дружку, как идиоты, а выполняются параллельно. Время — деньги, как говорил какой-то пидарас.
  2. Читать можно. Не эта ваша "адская пирамида колбэков", где глаза сломаешь, а чёткая цепочка методов. Слева направо, и всё ясно, в рот меня чих-пых.
  3. Гибкость — овердохуища. Хочешь дождаться всех — allOf(). Хочешь первого ответа — anyOf(). Запутался и упал — handle() тебя подхватит. В общем, инструмент на все случаи жизни, хуй с горы.
© ХакСобесов, 2026
support@hacksobesov.com