lecture

Author: onjsdnjs

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

@@ -7,37 +7,34 @@
 public class RunAsyncExample {
 
     public static void main(String[] args) {
+
         MyService myService = new MyService();
-        CompletableFuture<Void> voidFuture = CompletableFuture.runAsync(() -> {
-            // 비동기 작업 시뮬레이션
-            CompletableFuture<List<Integer>> future = myService.fetchDataAsync();
-            future.join().stream().forEach(System.out::println);
-        });
-        System.out.println("메인 작업 수행 중..");
+        CompletableFuture.runAsync(() -> {
+
+            List<Integer> list = myService.getData();
+            list.stream().forEach(System.out::println);
 
-        voidFuture.join();
+        }).join();
+
+        System.out.println("메인 작업 종료");
 
     }
 
     static class MyService {
 
-        public CompletableFuture<List<Integer>> fetchDataAsync() {
-
-            return CompletableFuture.supplyAsync(() -> {
-                // 비동기 작업 시뮬레이션
-                List<Integer> result = new ArrayList<>();
-                result.add(1);
-                result.add(2);
-                result.add(3);
+        public List<Integer> getData() {
 
-                try {
-                    Thread.sleep(1000); // 비동기 작업 시간 지연 시뮬레이션
-                } catch (InterruptedException e) {
-                    Thread.currentThread().interrupt();
-                }
+            List<Integer> result = new ArrayList<>();
+            result.add(1);
+            result.add(2);
+            result.add(3);
 
-                return result;
-            });
+            try {
+                Thread.sleep(1000); // 비동기 작업 시간 지연 시뮬레이션
+            } catch (InterruptedException e) {
+                Thread.currentThread().interrupt();
+            }
+            return result;
         }
     }
 }

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

@@ -9,32 +9,33 @@ public class SupplyAsyncExample {
     public static void main(String[] args) {
 
         MyService myService = new MyService();
+        CompletableFuture.supplyAsync(() -> {
 
-        CompletableFuture<List<Integer>> future = myService.fetchDataAsync();
-        System.out.println("메인 작업 수행 중..");
-        future.join().stream().forEach(System.out::println);
+            List<Integer> list = myService.getData();
+            list.stream().forEach(System.out::println);
+            return  list;
+
+        }).join();
+
+        System.out.println("메인 작업 종료");
 
     }
 
     static class MyService {
 
-        public CompletableFuture<List<Integer>> fetchDataAsync() {
-
-            return CompletableFuture.supplyAsync(() -> {
-                // 비동기 작업 시뮬레이션
-                List<Integer> result = new ArrayList<>();
-                result.add(1);
-                result.add(2);
-                result.add(3);
+        public List<Integer> getData() {
 
-                try {
-                    Thread.sleep(1000); // 비동기 작업 시간 지연 시뮬레이션
-                } catch (InterruptedException e) {
-                    Thread.currentThread().interrupt();
-                }
+            List<Integer> result = new ArrayList<>();
+            result.add(1);
+            result.add(2);
+            result.add(3);
 
-                return result;
-            });
+            try {
+                Thread.sleep(1000);
+            } catch (InterruptedException e) {
+                Thread.currentThread().interrupt();
+            }
+            return result;
         }
     }
 }