JAVA에서 비동기(Asynchronous) API 호출 예제

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

public class AsyncApiCallExample {

    // 가상의 API 호출 메서드 (시간이 오래 걸리는 작업이라고 가정)
    public static String callExternalApi(String query) {
        System.out.println("🔥 API 호출 시작: " + query + " (Thread: " + Thread.currentThread().getName() + ")");
        try {
            // API 응답 대기 시뮬레이션
            TimeUnit.SECONDS.sleep(2);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
        System.out.println("✅ API 호출 완료: " + query + " (Thread: " + Thread.currentThread().getName() + ")");
        return "API 응답 데이터 for " + query;
    }

    public static void main(String[] args) {
        System.out.println("🚀 메인 프로그램 시작 (Thread: " + Thread.currentThread().getName() + ")");

        // 1. CompletableFuture를 사용하여 비동기 호출 시작
        // supplyAsync는 별도의 스레드에서 작업을 실행하고 결과를 CompletableFuture에 담아 반환합니다.
        CompletableFuture<String> futureResult = CompletableFuture.supplyAsync(() -> 
            callExternalApi("User Data Request")
        );

        // 2. 비동기 작업이 진행되는 동안 다른 작업 수행 가능 (논블로킹)
        System.out.println("⏳ API 호출 결과를 기다리지 않고 다른 작업 수행 중...");
        try {
            TimeUnit.MILLISECONDS.sleep(500);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
        System.out.println("✅ 다른 작업 완료.");

        // 3. 비동기 작업이 완료된 후 후속 작업 정의 (콜백)
        // thenAccept는 결과가 준비되면 실행될 작업을 정의합니다.
        futureResult.thenAccept(result -> {
            System.out.println("⬇️ CompletableFuture 콜백 실행 (Thread: " + Thread.currentThread().getName() + ")");
            System.out.println("최종 결과 수신: " + result);
        });

        // 4. 결과가 준비될 때까지 메인 스레드 대기 (블로킹, 예제 실행을 위해 필요)
        // 실제 애플리케이션에서는 `.get()`을 호출하는 대신 콜백(`.thenApply`, `.thenAccept` 등)을 주로 사용합니다.
        try {
            // 이 시점에서 메인 스레드는 futureResult가 완료될 때까지 기다립니다.
            // *주의*: 실제 비동기의 이점을 살리려면 메인 스레드에서 바로 `.get()`을 호출하는 것은 피하는 것이 좋습니다.
            futureResult.get(); 
        } catch (InterruptedException | ExecutionException e) {
            e.printStackTrace();
        }

        System.out.println("🏁 메인 프로그램 종료 (Thread: " + Thread.currentThread().getName() + ")");
    }
}

🚀 메인 프로그램 시작 (Thread: main)
🔥 API 호출 시작: User Data Request (Thread: ForkJoinPool.commonPool-worker-1)
⏳ API 호출 결과를 기다리지 않고 다른 작업 수행 중...
✅ 다른 작업 완료.
✅ API 호출 완료: User Data Request (Thread: ForkJoinPool.commonPool-worker-1)
⬇️ CompletableFuture 콜백 실행 (Thread: ForkJoinPool.commonPool-worker-1)
최종 결과 수신: API 응답 데이터 for User Data Request
🏁 메인 프로그램 종료 (Thread: main)