Реализация асинхронного конвейера обработки данных

Вы разрабатываете аналитическую панель управления, которая должна получать данные пользователя и журналы активности из отдельных сервисов, а затем обрабатывать их для формирования сводки по пользователю. Эта операция должна выполняться асинхронно, чтобы приложение оставалось отзывчивым. Ваша задача — реализовать её с помощью CompletableFuture.

Классы UserData и UserSummary уже загружены для вас.

Это упражнение является частью курса

Оптимизация кода на Java

Посмотреть курс

Инструкции к упражнению

Добавьте получение данных пользователя в CompletableFuture.
Добавьте обработку данных пользователя в CompletableFuture.
Добавьте обработку исключений в CompletableFuture.

Интерактивное практическое упражнение

Попробуйте выполнить это упражнение, дополнив этот пример кода.

public class AsyncDashboard {
    public static void main(String[] args) throws Exception {        
        CompletableFuture userSummaryFuture = CompletableFuture
            // Fetch the user data
            .____(() -> fetchUserData("user123"))
            
            // Create summary based on fetched data
            .____(userData -> createSummary(userData))
            
            // Add exception handling
            .____(ex -> new UserSummary(new UserData("error", "Error User"))); 
        Thread.sleep(5000);
    }
    
    private static UserData fetchUserData(String userId) {
        simulateNetworkLatency(300);
        return new UserData(userId, "John Doe");
    }
    
    private static UserSummary createSummary(UserData userData) {
        simulateNetworkLatency(200);
        return new UserSummary(userData);
    }
    
    private static void simulateNetworkLatency(int millis) {
        try { Thread.sleep(millis); } catch (InterruptedException e) {}
    }
}

Редактировать и запускать код