From 7b0a613cccdd691ed983b74d0ad30d97c7fff586 Mon Sep 17 00:00:00 2001
From: javahongxi <javahongxi@qq.com>
Date: Sat, 15 Aug 2020 14:41:53 +0800
Subject: [PATCH] CompletableFuture

---
 .../hongxi/whatsmars/spring/boot/async/MessageService.java  | 6 +++++-
 .../hongxi/whatsmars/spring/boot/controller/InitRunner.java | 2 +-
 2 files changed, 6 insertions(+), 2 deletions(-)

diff --git a/whatsmars-spring-boot/src/main/java/org/hongxi/whatsmars/spring/boot/async/MessageService.java b/whatsmars-spring-boot/src/main/java/org/hongxi/whatsmars/spring/boot/async/MessageService.java
index 1fc296ed..afd7e6d1 100644
--- a/whatsmars-spring-boot/src/main/java/org/hongxi/whatsmars/spring/boot/async/MessageService.java
+++ b/whatsmars-spring-boot/src/main/java/org/hongxi/whatsmars/spring/boot/async/MessageService.java
@@ -3,6 +3,9 @@ package org.hongxi.whatsmars.spring.boot.async;
 import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Service;
 
+import java.util.Set;
+import java.util.concurrent.CompletableFuture;
+
 /**
  * Created by shenhongxi on 2018/5/8.
  */
@@ -10,7 +13,8 @@ import org.springframework.stereotype.Service;
 public class MessageService {
 
     @Async
-    public void send(String message) {
+    public CompletableFuture<String> send(String message) {
         System.out.println(message);
+        return CompletableFuture.completedFuture(message);
     }
 }
diff --git a/whatsmars-spring-boot/src/main/java/org/hongxi/whatsmars/spring/boot/controller/InitRunner.java b/whatsmars-spring-boot/src/main/java/org/hongxi/whatsmars/spring/boot/controller/InitRunner.java
index 6cb90978..6f79d322 100644
--- a/whatsmars-spring-boot/src/main/java/org/hongxi/whatsmars/spring/boot/controller/InitRunner.java
+++ b/whatsmars-spring-boot/src/main/java/org/hongxi/whatsmars/spring/boot/controller/InitRunner.java
@@ -29,7 +29,7 @@ public class InitRunner implements CommandLineRunner {
         userMapper.createIfNotExistsTable();
 
         for (int i = 0; i < 10; i++) {
-            messageService.send("message" + i);
+            logger.info("send result: {}", messageService.send("message" + i).get());
         }
     }
 }
-- 
GitLab