CompletableFuture异步编排示例

Posted 2022-08-23 小志的博客

目录

• • 一、开启异步编程
  • • 2.1、runAsync:无入参、无返回值
    • 2.2、supplyAsync ：无入参，可以获取返回值

一、开启异步编程

2.1、runAsync:无入参、无返回值

• 源码
  

• 示例代码

  package com.xz.thread.day1;
  
  import java.util.concurrent.*;
  /**
   * @description: 开启异步编程
   *              runAsync方法：无入参、无返回值
   * @author: xz
   * @create: 2022-08-21
   */
  public class Test1 
      /**
       * 定义线程池
       */
      public static ExecutorService service = Executors.newFixedThreadPool(3);
  
      public static void main(String[] args) 
          System.out.println("main start ...");
  
          CompletableFuture<Void> future = CompletableFuture.runAsync(() -> 
              System.out.println("开启异步任务...,runAsync方法，无入参、无返回值");
          , service);
  
          System.out.println("main end ...");
      
  
  
  

• 输出结果
  

• 由上图输出结果可知，主线程和异步线程可异步执行。并且异步线程无入参、无返回值。

2.2、supplyAsync ：无入参，可以获取返回值

• 源码
  

• 示例代码

  package com.xz.thread.day1;
  
  import lombok.SneakyThrows;
  import java.util.concurrent.*;
  /**
   * @description: 开启异步编程
   *               supplyAsync方法：无入参，可以获取返回值
   * @author: xz
   * @create: 2022-08-21
   */
  public class Test2 
      /**
       * 定义线程池
       */
      public static ExecutorService service = Executors.newFixedThreadPool(3);
  
      @SneakyThrows
      public static void main(String[] args) 
          System.out.println("main start ...");
  
          CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> 
              System.out.println("开启异步任务...");
              return "hello world!";
          , service);
  
          System.out.println("获取异步任务返回值：" + future.get());
          System.out.println("main end ...");
      
  
  

• 输出结果
  

• 由上图输出结果可知，主线程和异步线程可异步执行。并且异步线程无入参，可以获取返回值。