lecture

Author: onjsdnjs

src/main/java/io/concurrency/chapter11/exam10/CompleteOnTimeoutExample.java

@@ -6,22 +6,20 @@
 public class CompleteOnTimeoutExample {
     public static void main(String[] args) {
 
-        CompletableFuture<String> cf = CompletableFuture.supplyAsync(() -> {
+        getData().completeOnTimeout("Hello Java", 1, TimeUnit.SECONDS)
+        .thenAccept(result -> {
+            System.out.println("결과: " + result);
+        }).join();
+    }
+
+    private static CompletableFuture<String> getData() {
+        return CompletableFuture.supplyAsync(() -> {
             try {
-                TimeUnit.SECONDS.sleep(2);
+                Thread.sleep(2000);
                 return "Hello World";
             } catch (InterruptedException e) {
                 throw new RuntimeException(e);
             }
         });
-
-        CompletableFuture<String> cf2 = cf
-                .completeOnTimeout("Hello Java", 1, TimeUnit.SECONDS);
-
-        // 결과 처리
-        cf2.thenAccept(result -> {
-            System.out.println("결과: " + result);
-        }).join();
     }
-
 }

src/main/java/io/concurrency/chapter11/exam10/isCompletedExceptionallyAndIsCancelledExample.java

@@ -8,50 +8,31 @@ public class isCompletedExceptionallyAndIsCancelledExample {
 
     public static void main(String[] args) throws InterruptedException, ExecutionException, TimeoutException {
 
-        CompletableFuture<Integer> cf1 = CompletableFuture.supplyAsync(() -> {
-            sleep(1000);
-            return 10;
-        });
-
+        CompletableFuture<Integer> cf1 = CompletableFuture.supplyAsync(() -> 10);
         CompletableFuture<Integer> cf2 = CompletableFuture.supplyAsync(() -> {
-            sleep(2000);
-            return 10;
-//            throw new RuntimeException("두 번째 작업에서 예외 발생");
-        });
-
-        CompletableFuture<Integer> cf3 = CompletableFuture.supplyAsync(() -> {
-            sleep(1000);
             return 20;
+//            throw new RuntimeException("error");
         });
 
 //        cf2.cancel(true);
 
-        CompletableFuture<Integer> combinedFuture = cf1.thenCombine(cf2.exceptionally(e -> 15), (result1, result2) -> {
+        CompletableFuture<Integer> combinedFuture =
+                cf1.thenCombine(cf2.exceptionally(e -> 15), (result1, result2) -> {
 
-                if (cf2.isCancelled()) { // isDone() 과 구분할 수 있다
-                    return 0;
+                    if (cf2.isCancelled()) {
+                        return 0; // 취소 완료
+                    }
+                    else if (cf2.isCompletedExceptionally()) {
+                        return result2; // 예외 완료
+                    }
+                    else if(cf2.isDone()) {
+                        return result1 + result2; // 정상 완료
+                    }
+                    else return -1;
 
-                } else if (cf2.isCompletedExceptionally()) { // isDone() 과 구분할 수 있다
-                    return result2;
-
-                } else if(cf2.isDone()){
-                    return result1 + result2;
-                } else{
-
-                    return -1;
-                }
-             })
-            .thenCombine(cf3, (result2, result3) -> result2 + result3);
+             });
 
         int result = combinedFuture.join(); // 결과 가져오기
         System.out.println("최종 결과: " + result);
     }
-
-    private static void sleep(int milliseconds) {
-        try {
-            Thread.sleep(milliseconds);
-        } catch (InterruptedException e) {
-            Thread.currentThread().interrupt();
-        }
-    }
-}
+}