Java Future와 Callable 완전 정복 비동기 작업과 결과 처리 방법
⏳ Java에서 비동기 작업 수행과 결과 획득을 위한 핵심 개념과 실전 활용법
Java 멀티스레드 프로그래밍에서 비동기 작업을 효율적으로 처리하려면 Callable과 Future 인터페이스를 이해하는 것이 중요합니다.
Runnable과 달리 Callable은 작업 실행 후 결과를 반환할 수 있고, Future를 통해 비동기 작업의 완료 여부와 결과를 쉽게 관리할 수 있기 때문입니다.
이번 글에서는 Callable과 Future의 역할과 차이점을 자세히 설명하고, ExecutorService와 연계한 비동기 작업 실행 방법, Future를 통한 결과 획득과 예외 처리 방법을 구체적인 예제와 함께 안내합니다.
멀티스레드 환경에서 안전하고 효율적인 비동기 프로그래밍을 하고 싶다면 꼭 읽어보세요.
📋 목차
🔗 Callable과 Runnable의 차이
Java에서 Runnable은 실행할 작업의 내용을 정의하는 인터페이스로, run() 메서드를 구현하여 작업을 수행합니다.
하지만 Runnable은 작업이 끝난 후 결과를 반환하지 못하며 예외도 던질 수 없습니다.
반면에 Callable은 call() 메서드를 구현하며, 작업 수행 후 결과를 반환할 수 있고 예외도 던질 수 있습니다.
이로 인해 비동기 작업에서 결과를 받아야 하는 상황에 적합합니다.
📌 Runnable 예제
Runnable task = () -> {
System.out.println("Runnable 실행 중: " + Thread.currentThread().getName());
};
new Thread(task).start();
📌 Callable 예제
Callable<String> task = () -> {
return "Callable 작업 완료: " + Thread.currentThread().getName();
};
💎 핵심 포인트:
Runnable은 결과 없이 작업 수행에 집중할 때, Callable은 작업 결과가 필요할 때 사용합니다.
🛠️ Future를 이용한 비동기 결과 처리
Java의 Future 인터페이스는 비동기 작업의 결과를 나타내는 객체입니다.
비동기 작업이 완료되면 Future를 통해 작업 결과를 얻거나, 작업 진행 상태를 확인할 수 있습니다.
Future 객체는 get() 메서드를 통해 작업 결과를 반환받습니다.
만약 작업이 아직 완료되지 않았다면 get() 호출 시 결과가 준비될 때까지 대기(블로킹)합니다.
또한 cancel() 메서드를 사용해 작업을 취소할 수도 있습니다.
📌 Future 기본 사용 예제
import java.util.concurrent.*;
ExecutorService executor = Executors.newSingleThreadExecutor();
Callable<String> task = () -> {
Thread.sleep(1000);
return "작업 완료";
};
Future<String> future = executor.submit(task);
try {
String result = future.get(); // 결과 대기 및 획득
System.out.println(result);
} catch (InterruptedException | ExecutionException e) {
e.printStackTrace();
} finally {
executor.shutdown();
}
💎 핵심 포인트:
Future.get() 호출 시 작업이 완료될 때까지 블로킹되므로, 긴 작업은 타임아웃 설정이나 비동기 콜백 처리 방식을 고려해야 합니다.
⚙️ ExecutorService와 Callable 활용 예제
ExecutorService는 Callable과 Future를 활용해 비동기 작업을 효과적으로 실행하고 결과를 관리할 수 있는 인터페이스입니다.
스레드 풀을 이용해 여러 작업을 병렬로 처리하면서 결과를 받아올 수 있어 실무에서 널리 사용됩니다.
📌 ExecutorService와 Callable 실행 예제
import java.util.concurrent.*;
public class Main {
public static void main(String[] args) {
ExecutorService executor = Executors.newFixedThreadPool(3);
Callable<String> callableTask = () -> {
Thread.sleep(2000);
return "Callable 작업 완료: " + Thread.currentThread().getName();
};
Future<String> future = executor.submit(callableTask);
try {
String result = future.get();
System.out.println(result);
} catch (InterruptedException | ExecutionException e) {
e.printStackTrace();
} finally {
executor.shutdown();
}
}
}
💡 TIP: ExecutorService를 사용할 때는 작업이 완료된 후 반드시 shutdown()을 호출해 스레드 풀을 종료해야 합니다.
🔌 Future의 취소와 예외 처리 방법
Future 객체는 실행 중인 비동기 작업의 상태를 확인하고, 필요하면 작업을 취소할 수도 있습니다.
취소는 cancel() 메서드를 통해 수행하며, 작업이 아직 시작되지 않았거나 취소 가능 상태일 때만 성공합니다.
또한 Future.get()을 호출하면 작업이 완료될 때까지 대기하는데, 이 과정에서 작업 중 예외가 발생하면 ExecutionException이 발생합니다.
따라서 예외 처리를 반드시 해줘야 안정적인 코드가 됩니다.
📌 Future 취소 및 예외 처리 예제
Future<String> future = executor.submit(() -> {
Thread.sleep(3000);
return "완료";
});
// 작업 취소 시도
boolean cancelled = future.cancel(true);
System.out.println("취소 성공 여부: " + cancelled);
try {
String result = future.get(); // 작업이 취소되었으면 CancellationException 발생
System.out.println(result);
} catch (CancellationException e) {
System.out.println("작업이 취소되었습니다.");
} catch (InterruptedException | ExecutionException e) {
e.printStackTrace();
}
💎 핵심 포인트:
Future를 통한 작업 취소와 예외 처리는 비동기 작업을 안정적으로 관리하는 데 필수적입니다.
💡 Future와 CompletableFuture 비교 및 활용
Java 8부터 도입된 CompletableFuture는 Future의 한계를 보완한 고급 비동기 프로그래밍 도구입니다.
비동기 작업의 결과를 처리할 때 콜백, 체이닝, 결합 등 다양한 기능을 지원하여 복잡한 비동기 흐름도 간결하게 작성할 수 있습니다.
Future는 단순히 결과를 기다리고 얻는 데 중점을 둔 반면, CompletableFuture는 작업 완료 후 후속 작업 실행, 여러 비동기 작업 병합, 예외 처리 등 다양한 비동기 제어 기능을 제공합니다.
실시간 처리나 복잡한 비동기 연산이 필요한 경우 CompletableFuture를 사용하는 것이 더 적합합니다.
📌 CompletableFuture 간단 예제
import java.util.concurrent.CompletableFuture;
CompletableFuture.supplyAsync(() -> {
return "비동기 결과";
}).thenAccept(result -> {
System.out.println("결과 처리: " + result);
});
💎 핵심 포인트:
복잡한 비동기 흐름에서는 CompletableFuture를 활용해 코드 가독성과 유지보수성을 크게 향상시킬 수 있습니다.
❓ 자주 묻는 질문 (FAQ)
Callable과 Runnable의 가장 큰 차이점은 무엇인가요?
Future.get()이란 무엇인가요?
Future.cancel()은 어떻게 동작하나요?
CompletableFuture는 언제 사용하는 것이 좋나요?
ExecutorService를 사용한 작업은 어떻게 종료하나요?
Future.get() 호출 시 주의할 점은 무엇인가요?
비동기 작업 중 발생한 예외는 어떻게 처리하나요?
Future와 CompletableFuture의 차이는 무엇인가요?
📌 Java Future와 Callable 비동기 작업 완벽 이해
Java에서 비동기 작업을 수행할 때 Callable과 Future는 핵심 역할을 합니다.
Callable은 결과를 반환할 수 있는 작업 단위를 정의하며, Future는 이러한 작업의 비동기 실행 결과를 관리합니다.
ExecutorService와 결합하여 작업 제출, 결과 대기, 취소, 예외 처리까지 체계적인 비동기 프로그래밍이 가능합니다.
또한 Java 8 이후부터는 CompletableFuture를 통해 더 다양한 비동기 제어와 조합 기능도 지원되어 복잡한 비동기 로직도 쉽게 구현할 수 있습니다.
적절한 예외 처리와 스레드 풀 관리가 병행된다면, 안정적이고 효율적인 멀티스레드 애플리케이션을 개발할 수 있습니다.
🏷️ 관련 태그 : Java멀티스레드, Callable, Future, ExecutorService, CompletableFuture, 비동기작업, 멀티스레드결과처리, 예외처리, 스레드풀, 비동기프로그래밍