Thread가 종료될 때까지 기다릴 때 Thread.join()
을 사용할 수 있습니다.
예를 들어, Thread A는 Thread B에게 어떤 작업을 실행시키고 완료될 때까지 기다려야 할 때가 있습니다.
이럴 때 join()
을 호출하면 A는 B가 종료될 때까지 기다립니다.
Thread.join() 예제
다음과 같은 Thread 클래스가 있습니다. Thread가 실행되면 run()
이 호출됩니다.
public static class MyThread extends Thread {
@Override
public void run() {
System.out.println(LocalTime.now() + " Thread is started");
try {
Thread.sleep(3000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(LocalTime.now() + " Thread is exiting");
}
}
다음과 같이 MyThread
를 생성하고 start()
로 실행하면 main
과 MyThread
라는 두개의 쓰레드가 동시에 실행되게 됩니다.
main
쓰레드에서 thread.join()
을 호출하면 MyThread가 종료될 때까지 기다리게 됩니다.
public static void main(String args[]) throws InterruptedException {
MyThread thread = new MyThread();
System.out.println(LocalTime.now() + " Starting the thread");
thread.start();
System.out.println(LocalTime.now() + " Waiting the thread()");
thread.join();
System.out.println(LocalTime.now() + " alive: " + thread.isAlive());
}
결과를 보면 다음과 같습니다. MyThread가 종료될 때까지 기다린 후, isAlive()
로 쓰레드가 종료된 것을 확인하였습니다.
23:52:11.706 Starting the thread
23:52:11.708 Waiting the thread()
23:52:11.708 Thread is started
23:52:14.709 Thread is exiting
23:52:14.709 alive: false
join()을 사용하지 않는다면 ?
만약 join()
을 사용하지 않는다면, main Thread는 MyThread가 종료되는 것을 무시하고 다음 작업을 수행하게 됩니다.
MyThread thread = new MyThread();
System.out.println(LocalTime.now() + " Starting the thread");
thread.start();
System.out.println(LocalTime.now() + " alive: " + thread.isAlive());
결과를 보면, MyThread가 종료되지 않았는데 isAlive()
를 확인하고 있습니다.
23:51:18.030 Starting the thread
23:51:18.031 alive: true
23:51:18.031 Thread is started
23:51:21.031 Thread is exiting
Thread.join()에 Timeout 적용
join()
으로 어떤 Thread가 종료되길 기다리는데 예상하지 못한 이유로 종료되지 않을 수 있습니다. 이럴 때 join()
을 호출하는 Thread는 무한히 기다리게 되며, 프로그램은 응답없는 상태에 빠질 수 있습니다. 이럴 때 Timeout을 적용하면, 일정 시간 기다린 후 종료되지 않았을 때 join()
에서 빠져나와 다음 작업을 처리할 수 있습니다.
Timeout은 join(timeout)
와 같이 인자로 시간(ms)을 전달할 수 있습니다.
다음은 Timeout을 적용하는 예제입니다. 아래와 같이 MyThread
가 실행되면 10초 뒤에 종료됩니다.
public static class MyThread extends Thread {
@Override
public void run() {
System.out.println(
LocalTime.now() + " Thread is started");
try {
Thread.sleep(10000); // 10s
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println(
LocalTime.now() + " Thread is exiting");
}
}
그리고 join()
의 인자로 3초를 전달하면, join()
은 쓰레드가 종료될 때까지 기다리며 3초가 지나면 리턴되어 다음 코드를 수행합니다.
MyThread thread = new MyThread();
System.out.println(LocalTime.now() + " Starting the thread");
thread.start();
System.out.println(LocalTime.now() + " Waiting the thread()");
thread.join(3000);
System.out.println(LocalTime.now() + " alive: " + thread.isAlive());
실행 결과는 다음과 같습니다. join()
에서 리턴되었을 때 Thread가 종료되지 않은 상태이기 때문에 isAlive()
는 true
를 리턴합니다.
00:03:01.217 Starting the thread
00:03:01.217 Waiting the thread()
00:03:01.217 Thread is started
00:03:04.218 alive: true
00:03:11.218 Thread is exiting
Recommended Posts:
- Java - List와 Set의 차이점
- Java - substring()으로 문자열을 자르기
- Java - split()으로 문자열을 자르기
- Java - forEach 사용 방법
- Java - Timer, TimerTask
- Java - getPath(), getAbsolutePath(), getCanonicalPath()
- Java - Number Class
- Java - printf()로 문자열 포맷 출력
- Java - Float을 Byte 배열로 변환, Byte배열을 float으로 변환
- Java - 변수의 유효 범위 (Variable Scope)
- Java - instanceOf 연산자
- Java - Method Signature
- Java - 삼항연산자