CompletableFuture异步编排（开启异步编程代码示例）

源码

示例代码

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 future = CompletableFuture.runAsync(() -> {
            System.out.println("开启异步任务...,runAsync方法，无入参、无返回值");
        }, service);

        System.out.println("main end ...");
    }

}

输出结果

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

源码

示例代码

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 future = CompletableFuture.supplyAsync(() -> {
            System.out.println("开启异步任务...");
            return "hello world!";
        }, service);

        System.out.println("获取异步任务返回值：" + future.get());
        System.out.println("main end ...");
    }
}

输出结果

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