lecture

Author: onjsdnjs

src/main/java/io/concurrency/chapter11/exam04/RunAsyncExample.java

@@ -5,19 +5,18 @@
 import java.util.concurrent.CompletableFuture;
 
 public class RunAsyncExample {
-
     public static void main(String[] args) {
 
         MyService myService = new MyService();
+
         CompletableFuture.runAsync(() -> {
 
-            List<Integer> list = myService.getData();
-            list.stream().forEach(System.out::println);
+            System.out.println(Thread.currentThread().getName() + " 가 비동기 작업을 시작 합니다.");
+            List<Integer> result = myService.getData();
 
-        }).join();
-
-        System.out.println("메인 작업 종료");
+            result.stream().forEach(System.out::println);
 
+        }).join();
     }
 
     static class MyService {
@@ -30,7 +29,7 @@ public List<Integer> getData() {
             result.add(3);
 
             try {
-                Thread.sleep(1000); // 비동기 작업 시간 지연 시뮬레이션
+                Thread.sleep(1000);
             } catch (InterruptedException e) {
                 Thread.currentThread().interrupt();
             }

src/main/java/io/concurrency/chapter11/exam04/SupplyAsyncExample.java

@@ -5,20 +5,18 @@
 import java.util.concurrent.CompletableFuture;
 
 public class SupplyAsyncExample {
-
     public static void main(String[] args) {
 
         MyService myService = new MyService();
-        CompletableFuture.supplyAsync(() -> {
 
-            List<Integer> list = myService.getData();
-            list.stream().forEach(System.out::println);
-            return  list;
+        List<Integer> result = CompletableFuture.supplyAsync(() -> {
 
-        }).join();
+            System.out.println(Thread.currentThread().getName() + " 가 비동기 작업을 시작 합니다.");
+            return myService.getData();
 
-        System.out.println("메인 작업 종료");
+        }).join();
 
+        result.stream().forEach(System.out::println);
     }
 
     static class MyService {