lecture

Author: onjsdnjs

src/main/java/io/concurrency/chapter02/exam03/BlockedStateThreadExample.java

@@ -0,0 +1,26 @@
+package io.concurrency.chapter02.exam03;
+
+public class BlockedStateThreadExample {
+
+    public static void main(String[] args) throws InterruptedException {
+        final Object lock = new Object();
+        Thread thread1 = new Thread(() -> {
+            synchronized (lock) {
+                while (true) {
+                    // 무한 루프로 lock을 계속 점유
+                }
+            }
+        });
+        Thread thread2 = new Thread(() -> {
+            synchronized (lock) {
+                System.out.println("Thread 2 실행 중");
+            }
+        });
+        thread1.start();
+        Thread.sleep(100); // thread1이 lock을 점유하도록 잠시 대기
+        thread2.start();
+        Thread.sleep(100); // thread2가 lock을 기다리는 상태로 대기
+        System.out.println("스레드 2 상태: " + thread2.getState()); // BLOCKED
+    }
+
+}

src/main/java/io/concurrency/chapter02/exam03/NewStateThreadExample.java

@@ -0,0 +1,12 @@
+package io.concurrency.chapter02.exam03;
+
+public class NewStateThreadExample {
+
+    public static void main(String[] args) {
+        Thread thread = new Thread(() -> {
+            System.out.println("스레드 실행 중");
+        });
+        System.out.println("스레드 상태: " + thread.getState()); // NEW
+    }
+
+}

src/main/java/io/concurrency/chapter02/exam03/RunnableStateThreadExample.java

@@ -0,0 +1,18 @@
+package io.concurrency.chapter02.exam03;
+
+public class RunnableStateThreadExample {
+
+    public static void main(String[] args) throws InterruptedException {
+
+        Thread thread = new Thread(() -> {
+            while (true) {
+                for (int i = 0; i < 1000000000; i++) {
+                    if(i%1000000000 == 0){
+                        System.out.println("스레드 상태: " + Thread.currentThread().getState()); // RUNNABLE
+                    }
+                }
+            }
+        });
+        thread.start();
+    }
+}

src/main/java/io/concurrency/chapter02/exam03/TerminatedStateThreadExample.java

@@ -0,0 +1,14 @@
+package io.concurrency.chapter02.exam03;
+
+public class TerminatedStateThreadExample {
+
+    public static void main(String[] args) throws InterruptedException {
+        Thread thread = new Thread(() -> {
+            System.out.println("스레드 실행 중");
+        });
+        thread.start();
+        thread.join(); // 스레드가 종료될 때까지 기다림
+        System.out.println("스레드 상태: " + thread.getState()); // TERMINATED
+    }
+
+}

src/main/java/io/concurrency/chapter02/exam03/TimedWaitingStateThreadExample.java

@@ -0,0 +1,18 @@
+package io.concurrency.chapter02.exam03;
+
+public class TimedWaitingStateThreadExample {
+
+    public static void main(String[] args) throws InterruptedException {
+        Thread thread = new Thread(() -> {
+            try {
+                Thread.sleep(10000);
+            } catch (InterruptedException e) {
+                e.printStackTrace();
+            }
+        });
+        thread.start();
+        Thread.sleep(100);
+        System.out.println("스레드 상태: " + thread.getState()); // TIMED_WAITING
+    }
+
+}

src/main/java/io/concurrency/chapter02/exam03/WaitingStateThreadExample.java

@@ -0,0 +1,20 @@
+package io.concurrency.chapter02.exam03;
+
+public class WaitingStateThreadExample {
+
+    public static void main(String[] args) throws InterruptedException {
+        final Object lock = new Object();
+        Thread thread = new Thread(() -> {
+            synchronized (lock) {
+                try {
+                    lock.wait();
+                } catch (InterruptedException e) {
+                    e.printStackTrace();
+                }
+            }
+        });
+        thread.start();
+        Thread.sleep(100);
+        System.out.println("스레드 상태: " + thread.getState()); // WAITING
+    }
+}