lecture

Author: onjsdnjs

src/main/java/io/concurrency/chapter11/exam06/ThenAcceptExample.java

@@ -20,11 +20,13 @@ public static void main(String[] args) {
                 })
                 .thenAccept(result -> {
                     System.out.println("thread2:" + Thread.currentThread().getName());
+                    System.out.println("결과: " + result);
                     List<Integer> r = myService.getData1();
                     r.forEach(System.out::println);
 
                 }).thenAcceptAsync(result -> {
                     System.out.println("thread3:" + Thread.currentThread().getName());
+                    System.out.println("결과: " + result);
                     List<Integer> r = myService.getData2();
                     r.forEach(System.out::println);
 

src/main/java/io/concurrency/chapter11/exam06/ThenRunExample.java

@@ -38,7 +38,6 @@ public static void main(String[] args) {
         System.out.println("모든 작업 완료");
 
     }
-
     static class MyService {
 
         public List<Integer> getData1(){

src/main/java/io/concurrency/chapter11/exam07/ThenCombineExample.java

@@ -7,8 +7,8 @@ public static void main(String[] args){
 
         MyService myService = new MyService();
 
-        CompletableFuture<String> cf1 = myService.fetchAsyncData(); // 비동기 작업 1
-        CompletableFuture<String>  cf2 = myService.fetchAsyncData2();
+        CompletableFuture<String> cf1 = myService.getData1(); // 비동기 작업 1
+        CompletableFuture<String>  cf2 = myService.getData2();
 
         CompletableFuture<String> cf3 = cf1.thenCombine(cf2, (r1, r2) -> r1 + r2);
 
@@ -19,7 +19,7 @@ public static void main(String[] args){
 
     static class MyService {
 
-        public CompletableFuture<String> fetchAsyncData() {
+        public CompletableFuture<String> getData1() {
             return CompletableFuture.supplyAsync(() -> {
                 try {
                     Thread.sleep(500); // 2초 동안 대기
@@ -30,7 +30,7 @@ public CompletableFuture<String> fetchAsyncData() {
             });
         }
 
-        public CompletableFuture<String> fetchAsyncData2() {
+        public CompletableFuture<String> getData2() {
             return CompletableFuture.supplyAsync(() -> {
                 try {
                     Thread.sleep(500); // 2초 동안 대기
@@ -40,9 +40,5 @@ public CompletableFuture<String> fetchAsyncData2() {
                 return "World";
             });
         }
-
-        public int performData(int input) {
-            return input + 10;
-        }
     }
 }

src/main/java/io/concurrency/chapter11/exam07/ThenComposeExample.java

@@ -9,20 +9,20 @@ public static void main(String[] args) throws ExecutionException, InterruptedExc
 
         MyService myService = new MyService();
 
-        CompletableFuture<Integer> asyncTask1 = myService.fetchAsyncData(5); // 비동기 작업 1
+        CompletableFuture<Integer> asyncTask1 = myService.getData1(5); // 비동기 작업 1
         CompletableFuture<Integer> asyncTask2 = asyncTask1.thenCompose(result -> {
             // 이전 비동기 작업의 결과를 사용 하여 다른 비동기 작업 실행
-            return myService.fetchAsyncData2(result);
+            return myService.getData2(result);
         });
 
-        int finalResult = myService.performData(asyncTask2.get());
+        int finalResult = asyncTask2.get();
 
         System.out.println("final result: " + finalResult);
     }
 
     static class MyService {
 
-        public CompletableFuture<Integer> fetchAsyncData(int input) {
+        public CompletableFuture<Integer> getData1(int input) {
             return CompletableFuture.supplyAsync(() -> {
                 try {
                     Thread.sleep(500); // 2초 동안 대기
@@ -34,7 +34,7 @@ public CompletableFuture<Integer> fetchAsyncData(int input) {
         }
 
         // 호출 되는 함수가 비동기로 실행 된 후 반환 값이 CompletableFuture 로 되는 경우
-        public CompletableFuture<Integer> fetchAsyncData2(int input) {
+        public CompletableFuture<Integer> getData2(int input) {
             return CompletableFuture.supplyAsync(() -> {
                 try {
                     Thread.sleep(500); // 2초 동안 대기
@@ -44,9 +44,5 @@ public CompletableFuture<Integer> fetchAsyncData2(int input) {
                 return input * 2;
             });
         }
-
-        public int performData(int input) {
-            return input + 10;
-        }
     }
 }