Structured Concurrency (Java 21 Preview)

Java code

import java.util.concurrent.*;
import jdk.incubator.concurrent.StructuredTaskScope;

// Java 21 Preview — 구조화된 동시성
record UserProfile(String name, int orderCount, double credit) {}

UserProfile fetchProfile(long userId) throws Exception {
    // ShutdownOnFailure: 하나라도 실패 시 나머지 자동 취소
    try (var scope = new StructuredTaskScope.ShutdownOnFailure()) {

        // 3개의 하위 작업 동시 실행
        Subtask<String> nameTask =
            scope.fork(() -> fetchUserName(userId));
        Subtask<Integer> orderTask =
            scope.fork(() -> fetchOrderCount(userId));
        Subtask<Double> creditTask =
            scope.fork(() -> fetchCredit(userId));

        // 모든 작업 완료 대기 (또는 실패 시 즉시 반환)
        scope.join()
             .throwIfFailed();

        // 모든 결과 수집
        return new UserProfile(
            nameTask.get(),
            orderTask.get(),
            creditTask.get()
        );
    }
    // try 블록 종료 시 미완료 작업 자동 취소
}

// ShutdownOnSuccess: 가장 빠른 성공 결과만 사용
String fetchFromMirrors(String key) throws Exception {
    try (var scope = new StructuredTaskScope.ShutdownOnSuccess<String>()) {
        scope.fork(() -> fetchFromMirror1(key));
        scope.fork(() -> fetchFromMirror2(key));
        scope.fork(() -> fetchFromMirror3(key));

        scope.join();
        return scope.result(); // 가장 먼저 성공한 결과
    }
}