study

Author: june0313

src/main/java/io/concurrency/chapter01/exam01/ConcurrencyExample.java

@@ -6,8 +6,8 @@
 public class ConcurrencyExample {
     public static void main(String[] args) {
 
-        int cpuCores = Runtime.getRuntime().availableProcessors() * 2;
-//        int cpuCores = 13;
+//        int cpuCores = Runtime.getRuntime().availableProcessors() * 2;
+        int cpuCores = 30;
 
         // CPU 개수를 초과하는 데이터를 생성
         List<Integer> data = new ArrayList<>();
@@ -20,6 +20,7 @@ public static void main(String[] args) {
         long sum2 = data.parallelStream()
                 .mapToLong(i -> {
                     try {
+                        System.out.println("Thread: " + Thread.currentThread().getName() + " " + i);
                         Thread.sleep(500);
                     } catch (InterruptedException e) {
                         throw new RuntimeException(e);

src/main/java/io/concurrency/chapter01/exam03/CPUBoundExample.java

@@ -36,15 +36,15 @@ public static void main(String[] args) throws InterruptedException {
             });
             futures.add(future);
         }
-        futures.forEach(f -> {
-            try {
-                f.get();
-            } catch (InterruptedException e) {
-                throw new RuntimeException(e);
-            } catch (ExecutionException e) {
-                throw new RuntimeException(e);
-            }
-        });
+//        futures.forEach(f -> {
+//            try {
+//                f.get();
+//            } catch (InterruptedException e) {
+//                throw new RuntimeException(e);
+//            } catch (ExecutionException e) {
+//                throw new RuntimeException(e);
+//            }
+//        });
         long endTime2 = System.currentTimeMillis();
         System.out.println("CPU 개수를 초과하는 데이터를 병렬로 처리하는 데 걸린 시간: " + (endTime2 - startTime2) + "ms");
         executorService.shutdown();

src/main/java/io/concurrency/chapter01/exam03/IOBoundExample.java

@@ -17,7 +17,7 @@ public static void main(String[] args) {
 
                     // IO 가 집중 되는 작업
                     for (int j = 0; j < 5; j++) {
-                        Files.readAllLines(Path.of("D:\\lecture\\Java-Concurrency-Programming\\Java-Concurrency-Programming\\src\\chapter01\\exam03\\sample.txt"));
+                        Files.readAllLines(Path.of("/Users/youngjun/study/Java-Concurrency-Programming/src/main/java/io/concurrency/chapter01/exam03/sample.txt"));
                         System.out.println("스레드: " + Thread.currentThread().getName() +", " +j); // IO Bound 일때 ContextSwitching 이 일어난다
                     }
 

src/main/java/io/concurrency/chapter02/exam02/MultiThreadAppTerminatedExample.java

@@ -4,7 +4,7 @@ public class MultiThreadAppTerminatedExample {
     public static void main(String[] args) {
 
         for (int i = 0; i < 3; i++) {
-            Thread thread = new Thread(new ThreadStackExample.MyRunnable(i));
+            Thread thread = new Thread(new MyRunnable(i));
             thread.start();
         }
 

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

@@ -0,0 +1,8 @@
+package io.concurrency.chapter02.exam03;
+
+public class StatusTest {
+    public static void main(String[] args) {
+        Thread thread = new Thread(() -> System.out.println("hahaha"));
+        System.out.println(thread.getState());
+    }
+}

src/main/java/io/concurrency/chapter03/exam01/BasicSleepExample.java

@@ -8,6 +8,7 @@ public static void main(String[] args) {
             System.out.println("Hello World");
 
         } catch (InterruptedException e) {
+            System.out.println("Interrupted");
             throw new RuntimeException(e);
         }
     }

src/main/java/io/concurrency/chapter03/exam01/InterruptSleepExample.java

@@ -18,7 +18,7 @@ public static void main(String[] args) throws InterruptedException {
 
         sleepingThread.start();
 
-        Thread.sleep(1000);
+        Thread.sleep(3000);
 //
         sleepingThread.interrupt();
     }