Thread는 Runnable과 Callable의 구현된 함수를 수행한다는 공통점이 있지만, 다음과 같은 차이점이 있습니다.
- Runnable: 어떤 객체도 리턴하지 않습니다. Exception을 발생시키지 않습니다.
- Callable: 특정 타입의 객체를 리턴합니다. Exception을 발생킬 수 있습니다.
Runnable
다음은 Runnable 인터페이스 코드입니다. 인자를 받지 않고 리턴값이 없습니다.
public interface Runnable {
public abstract void run();
}다음은 Runnable을 사용하는 예제입니다. Thread는 Runnable을 인자로 받고 실행합니다. 어떤 값도 리턴하지 않으며, Runnable의 run() 메소드에 정의된 코드를 수행합니다.
package utils;
import java.time.LocalTime;
public class RunnableExample1 {
static class MyRunnable implements Runnable {
@Override
public void run() {
String result = "Called at " + LocalTime.now();
System.out.println(result);
}
}
public static void main(String[] args) {
MyRunnable runnable = new MyRunnable();
Thread thread = new Thread(runnable);
thread.start();
}
}결과
Called at 21:13:10.332위 코드는 다음과 같이 람다식(Lambda)으로 표현할 수 있습니다.
public class RunnableExample2 {
public static void main(String[] args) {
Thread thread = new Thread(
() -> System.out.println("Runnable at " + LocalTime.now()));
thread.start();
}
}Callable
다음은 Callable 인터페이스 코드입니다. 인자를 받지 않으며, 특정 타입의 객체를 리턴합니다. 또한 call() 메소드 수행 중 Exception을 발생시킬 수 있습니다.
public interface Callable<V> {
V call() throws Exception;
}다음은 Callable을 사용하는 예제입니다. Thread는 FutureTask를 통해서 Callable을 호출합니다.
FutureTask.get()으로 Callable의 call()메소드가 호출되어 결과가 리턴되기를 기다립니다.
package utils;
import java.time.LocalTime;
import java.util.concurrent.*;
public class CallableExample1 {
static class MyCallable implements Callable<String> {
@Override
public String call() throws Exception {
String result = "Called at " + LocalTime.now();
return result;
}
}
public static void main(String[] args) throws ExecutionException, InterruptedException {
MyCallable callable = new MyCallable();
FutureTask futureTask = new FutureTask(callable);
Thread thread = new Thread(futureTask);
thread.start();
// 결과가 리턴되기를 기다립니다.
System.out.println("result : " + futureTask.get());
}
}결과
result : Called at 21:17:54.051ExecutorService
ExecutorService도 Callable을 Job으로 등록하고 수행시킬 수 있습니다. 다음 코드처럼 Future를 이용하여 결과를 리턴받을 수 있습니다.
package utils;
import java.time.LocalTime;
import java.util.concurrent.*;
public class CallableExample2 {
static class MyCallable implements Callable<String> {
@Override
public String call() throws Exception {
String result = "Called at " + LocalTime.now();
return result;
}
}
public static void main(String[] args) throws ExecutionException, InterruptedException {
MyCallable callable = new MyCallable();
ExecutorService executor = Executors.newSingleThreadExecutor();
Future<String> future = executor.submit(callable);
// 결과가 리턴되기를 기다립니다.
System.out.println("result : " + future.get());
}
}결과
result : Called at 21:19:25.693위 코드도 다음처럼 람다식(Lambda)으로 표현할 수 있습니다.
public class CallableExample3 {
public static void main(String[] args) throws ExecutionException, InterruptedException {
ExecutorService executor = Executors.newSingleThreadExecutor();
Future<String> future = executor.submit(() -> "Called at " + LocalTime.now());
// 결과가 리턴되기를 기다립니다.
System.out.println("result : " + future.get());
}
}Recommended Posts:
- Java - throw와 throws의 차이점
- Java - 접근제어자(Access Modifier)
- Gson - Java Object, JSON Object 변환
- Java - final, finally, finalize의 차이점
- Java - Static 키워드 이해하기
- Java - Final 키워드에 대한 이해
- Java - Lambda, 익명 클래스에서 final 변수를 참조해야하는 이유
- Java - split, substring으로 문자열을 자르기 & 분리하기
- Java - Generics에서 Covariance, Contravariance 개념 이해하기
- Java의 Effectively final이란 무엇인가?
- Java - 정규표현식(regex), 다양한 예제로 쉽게 이해하기
- Java - Thread 우선순위(Priority)를 설정하는 방법
- Java - Reflection 쉽고 빠르게 이해하기