Java - Thread.join() 소개, 쓰레드 종료 대기

javabasic

자바에서 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
Loading script...

Related Posts

codechachaCopyright ©2019 codechacha