CompletableFuture

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);
     }
 }

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());
         }
     }
 }