join()

Author: yaewon0411

src/main/java/io/concurrency/chapter03/exam02/BasicJoinExample.java

@@ -2,9 +2,9 @@
 
 public class BasicJoinExample {
 
-    public static void main(String[] args) {
+    public static void main(String[] args) { //메인 함수의 메인 스레드가 일종의 부모 스레드
 
-        Thread thread = new Thread(() -> {
+        Thread thread = new Thread(() -> { //메인 스레드의 자식 스레드
             try {
                 System.out.println("스레드가 3초 동안 작동합니다.");
                 Thread.sleep(5000);
@@ -18,14 +18,16 @@ public static void main(String[] args) {
 
         System.out.println("메인 스레드가 다른 스레드의 완료를 기다립니다.");
 
-        try {
 
-            thread.join();
+        try {
+            //메인 스레드가 대상(자식) 스레드에게 join()을 걸고 있다!
+            thread.join(); //자식 스레드가 완료될 때까지 대기
 
         } catch (InterruptedException e) {
             throw new RuntimeException(e);
         }
 
         System.out.println("메인 스레드가 계속 진행합니다");
+
     }
 }

src/main/java/io/concurrency/chapter03/exam02/InterruptedJoinExample.java

@@ -9,20 +9,20 @@ public static void main(String[] args) {
         Thread longRunningThread = new Thread(() -> {
             try {
                 for (int i = 0; i < 10; i++) {
-                    System.out.println("긴 작업 스레드가 계속 실행 중...");
+                    System.out.println("긴 스레드가 계속 실행 중...");
                     Thread.sleep(1000);
                 }
             } catch (InterruptedException e) {
                 mainThread.interrupt();
-                System.out.println("긴 작업 스레드가 인터럽트 되었습니다.");
+                System.out.println("긴 작업 스레드가 인터럽트 되었습니다");
             }
         });
 
         longRunningThread.start();
 
         Thread interruptingThread = new Thread(() -> {
             try {
-                System.out.println("인터럽트 스레드가 2초 후에 긴 작업 스레드를 인터럽트 합니다.");
+                System.out.println("인터럽트 스레드가 2초 후에 긴 작업 스레드를 인터럽트 합니다");
                 Thread.sleep(2000);
                 longRunningThread.interrupt();
             } catch (InterruptedException e) {
@@ -32,15 +32,54 @@ public static void main(String[] args) {
 
         interruptingThread.start();
 
-
-        try {
+        //메인 스레드가 조인에서 빠져나오는 것을 확인하자
+        //즉 메인 스레드에게 인터럽트를 걸어야 한다!!
+        try{
             System.out.println("메인 스레드가 긴 작업 스레드의 완료를 기다립니다.");
             longRunningThread.join();
             System.out.println("메인 스레드 작업 완료");
-
-        } catch (InterruptedException e) {
-            System.out.println("메인 스레드가 인터럽트 되었습니다.");
-            throw new RuntimeException(e);
+        }catch (InterruptedException e){
+            System.out.println("메인 스레드가 인터럽트 되었습니다");
         }
+
+
+//        Thread mainThread = Thread.currentThread();
+//
+//        Thread longRunningThread = new Thread(() -> {
+//            try {
+//                for (int i = 0; i < 10; i++) {
+//                    System.out.println("긴 작업 스레드가 계속 실행 중...");
+//                    Thread.sleep(1000);
+//                }
+//            } catch (InterruptedException e) {
+//                mainThread.interrupt();
+//                System.out.println("긴 작업 스레드가 인터럽트 되었습니다.");
+//            }
+//        });
+//
+//        longRunningThread.start();
+//
+//        Thread interruptingThread = new Thread(() -> {
+//            try {
+//                System.out.println("인터럽트 스레드가 2초 후에 긴 작업 스레드를 인터럽트 합니다.");
+//                Thread.sleep(2000);
+//                longRunningThread.interrupt();
+//            } catch (InterruptedException e) {
+//                throw new RuntimeException(e);
+//            }
+//        });
+//
+//        interruptingThread.start();
+//
+//
+//        try {
+//            System.out.println("메인 스레드가 긴 작업 스레드의 완료를 기다립니다.");
+//            longRunningThread.join();
+//            System.out.println("메인 스레드 작업 완료");
+//
+//        } catch (InterruptedException e) {
+//            System.out.println("메인 스레드가 인터럽트 되었습니다.");
+//            throw new RuntimeException(e);
+//        }
     }
 }

src/main/java/io/concurrency/chapter03/exam02/MultiThreadJoinExample.java

@@ -31,6 +31,7 @@ public static void main(String[] args) throws InterruptedException {
         thread1.join();
         thread2.join();
 
+
         System.out.println("메인 스레드가 계속 진행합니다");
 
     }

src/main/java/io/concurrency/chapter03/exam02/README.md

@@ -0,0 +1,51 @@
+# InterruptedJoinExample
+
+조인을 호출하는 스레드와, 조인의 대상이 되는 스레드와, 조인에서 인터럽트 되는 스레드를 잘 구분 지어야 한다
+
+가정)<br>
+메인 스레드 -> 조인을 호출하는 스레드 <br>
+스레드 1 -> 조인의 대상이 되는 스레드. 인터럽트 되면 자신을 호출한 메서드를 인터럽트 시킴<br>
+스레드 2 -> 스레드 1을 인터럽트 시키는 스레드<br>
+
+
+```java
+
+try{
+    //메인 스레드 코드 블럭
+    스레드1.start(); // 스레드 1 실행
+    
+    스레드1.join(); //메인 스레드가 일시 중지 상태에 들어감
+
+    스레드2.start(); //스레드 1을 인터럽트 시키는 스레드 실행
+
+    //스레드 1 인터럽트 발생 -> InterruptedException 발생
+
+    //스레드 1의 InterruptedException에 의해 메인 스레드 인터럽트
+
+    // 메인 스레드의 인터럽트 발생 -> InterruptedException 발생
+
+    System.out.println("메인 스레드가 작업이 정상적으로 종료되었습니다");
+    
+    }catch (InterruptedException e){
+        System.out.println("메인 스레드가 인터럽트 되었습니다"); //해당 문구가 출력됨
+    }
+```
+이에 따라 스레드 1은 메인 스레드를 인터럽트하는 코드를 갖고 있어야 한다
+
+```java
+        Thread mainThread = Thread.currentThread();
+
+        Thread longRunningThread = new Thread(() -> {
+            try {
+                for (int i = 0; i < 10; i++) {
+                    System.out.println("긴 스레드가 계속 실행 중...");
+                    Thread.sleep(1000);
+                }
+            } catch (InterruptedException e) {
+                mainThread.interrupt();
+                System.out.println("긴 작업 스레드가 인터럽트 되었습니다");
+            }
+        });
+```
+
+### join을 호출한 스레드가 인터럽트를 받아야 wait()에서 빠져나오고 Runnable로 전환