lecture

Author: onjsdnjs

src/main/java/io/concurrency/chapter11/exam03/CompletableFutureExample.java

@@ -9,6 +9,7 @@ public static void main(String[] args) throws ExecutionException, InterruptedExc
 
         CompletableFuture<Object> handle = CompletableFuture.supplyAsync(() -> 2)
                 .thenApplyAsync(result -> result + 3)
+//                .thenApplyAsync(result -> {throw new RuntimeException("error");})
                 .handle((result, exception) -> {
                     if (exception != null) {
                         System.out.println("예외 발생: " + exception.getMessage());

src/main/java/io/concurrency/chapter11/exam03/CompletableTask.java

@@ -7,12 +7,12 @@
 
 public class CompletableTask {
     public static void main(String[] args) {
-        ExecutorService executorService = Executors.newFixedThreadPool(2);
+
+        ExecutorService executorService = Executors.newFixedThreadPool(1);
         CompletableFuture<Integer> future = new CompletableFuture<>();
 
         executorService.submit(() -> {
-            int result = performTask();
-            future.complete(result + 10); // 결과 조작 하고 즉시 완료 시킴
+            future.complete(5); // 결과 조작 하고 즉시 완료 시킴
         });
 
         try {
@@ -24,8 +24,7 @@ public static void main(String[] args) {
 
         executorService.shutdown();
     }
-
     private static int performTask(){
         return 5;
     }
-}
+}

src/main/java/io/concurrency/chapter11/exam03/ExecutorServiceExample.java

@@ -1,6 +1,9 @@
-package chapter11.exam03;
+package io.concurrency.chapter11.exam03;
 
-import java.util.concurrent.*;
+import java.util.concurrent.ExecutionException;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+import java.util.concurrent.Future;
 
 public class ExecutorServiceExample {
 

src/main/java/io/concurrency/chapter11/exam03/NonCompletableTask.java

@@ -1,17 +1,15 @@
 package io.concurrency.chapter11.exam03;
 
-import java.util.concurrent.*;
+import java.util.concurrent.ExecutionException;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+import java.util.concurrent.Future;
 
 public class NonCompletableTask {
     public static void main(String[] args) {
-        ExecutorService executorService = Executors.newFixedThreadPool(2);
 
-        Callable<Integer> task = () -> {
-            int result = performTask();
-            return result;  // 결과 리턴 후 완료 됨
-        };
-
-        Future<Integer> future = executorService.submit(task);
+        ExecutorService executorService = Executors.newFixedThreadPool(1);
+        Future<Integer> future = executorService.submit(() -> 5);
 
         try {
             int result = future.get() + 10;
@@ -22,7 +20,4 @@ public static void main(String[] args) {
 
         executorService.shutdown();
     }
-    private static int performTask(){
-        return 5;
-    }
 }