脚本之家 服务器常用软件
快捷导航
您的位置：首页 → 软件编程 → java → Java8 CompletableFuture 异步执行

Java8 CompletableFuture 异步执行操作

 更新时间：2021年06月22日 18:02:04   作者：ACGkaka_  
CompletableFuture是java8提供的基于异步操作的封装，日常开发中经常会用到，接下来通过本文给大家介绍Java8 CompletableFuture 异步执行操作，感兴趣的朋友一起看看吧

1.简介

CompletableFuture 是 JDK8 提供的一个异步执行工具。

示例1：

public static void main(String[] args) throws ExecutionException, InterruptedException {
    CompletableFuture<Void> future = CompletableFuture.runAsync(() -> {
        for (int i = 0; i < 3; i++) {
            System.out.println(i);
            try {
                Thread.sleep(1000L);
            } catch (InterruptedException ignored) {
            }
        }
        System.out.println("Future Finished.");
    });
    System.out.println("Main Thread Finished.");
    future.get();
}

输出结果1：

2.异步执行

CompletableFuture 提供了两个方法用于异步执行：

CompletableFuture.runAsync，没有返回值；
CompletableFuture.supplyAsync，有返回值。

示例：

public static void main(String[] args) throws ExecutionException, InterruptedException {
    // runAsync 没有返回值
    CompletableFuture<Void> future1 = CompletableFuture.runAsync(() -> System.out.println("future1 executed."));
    // supplyAsync 有返回值
    CompletableFuture<Object> future2 = CompletableFuture.supplyAsync(() -> {
        System.out.println("future2 executed.");
        return "result";
    });

    System.out.println("future1.get(): " + future1.get());
    System.out.println("future2.get(): " + future2.get());
}

输出结果：

3.守护线程

CompletableFuture返回的Future默认为守护线程，如果不调用get()获取结果，主线程结束后会自动结束。主要有以下4种情景：

  • 情景1： 执行时间 > 主线程时间，异步线程会执行；
  • 情景2： 执行时间 > 主线程，是守护线程，会被杀死，异步线程不会执行；
  • 情景3： 执行时间 > 主线程，但是不是守护线程，不会被杀死，异步线程会执行；
  • 情景4： ExecutorService.submit()，默认不是守护线程，不会被杀死，异步线程会执行。

示例：

public static void main(String[] args) {
    ExecutorService executorService = Executors.newFixedThreadPool(2);
    // 1.执行时间 < 主线程，会打印
    CompletableFuture<Void> future1 = CompletableFuture.runAsync(() ->
		System.out.println("Thread1 是否为守护线程 : " + Thread.currentThread().isDaemon()));

    // 2.执行时间 > 主线程，是守护线程，会被杀死，不会打印
    CompletableFuture.runAsync(() -> {
        try {
            Thread.sleep(3000L);
            System.out.println("Thread2 是否为守护线程 : " + Thread.currentThread().isDaemon());
        } catch (InterruptedException e) {
            e.printStackTrace();
        }});

    // 3.执行时间 > 主线程，但是不是守护线程，不会被杀死，会打印
    CompletableFuture.runAsync(() -> {
        try {
            Thread.sleep(1000L);
            System.out.println("Thread3 等待1秒");
            System.out.println("Thread3 是否为守护线程 : " + Thread.currentThread().isDaemon());
        } catch (InterruptedException e) {
            e.printStackTrace();
        }}, executorService);

    // 4.ExecutorService.submit()，默认不是守护线程，不会被杀死，会打印。
    executorService.submit(() -> {
        try {
            Thread.sleep(2000L);
            System.out.println("Thread4 等待2秒");
            System.out.println("Thread4 是否为守护线程 : " + Thread.currentThread().isDaemon());
        } catch (InterruptedException e) {
            e.printStackTrace();
        }});

    // 主线程执行完毕
    System.out.println("Main Thread Finished.");
    executorService.shutdown();
}

输出结果2：

4.处理执行结果

CompletableFuture还封装了很多处理执行结果操作。操作太多，列举比较常用的几种：

thenAccept()： 对结果进行使用；
thenApply()： 对结果进行转换；
exceptionally()： 对异常进行处理；
whenComplete()： 相当于 thenAccept() + thenApply() + exceptionally().

示例：

public static void main(String[] args) {
    // thenAccept对结果进行使用
    System.out.println("------------------------------");
    CompletableFuture.supplyAsync(() -> "Thread1 Finished.").thenAccept(System.out::println);

    // thenApply对结果进行转换
    System.out.println("------------------------------");
    CompletableFuture.supplyAsync(() -> "Thread2 Finished.")
        .thenApply(s -> s + " + thenApply()")
        .thenAccept(System.out::println);

    // exceptionally对异常进行处理
    System.out.println("------------------------------");
    CompletableFuture.supplyAsync(() -> {throw new RuntimeException("Thread3 Failed.");})
        .exceptionally(Throwable::toString).thenAccept(System.out::println);

    // 主线程执行完毕
    System.out.println("------------------------------");
    System.out.println("Main Thread Finished.");
}

输出结果：

whenComplete() 示例：

public static void main(String[] args) throws ExecutionException, InterruptedException {
    // thenAccept对结果进行使用
    System.out.println("------------------------------");
    CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> "Thread1 Finished.").whenComplete(new BiConsumer<String, Throwable>() {
        @Override
        public void accept(String s, Throwable throwable) {
            System.out.println("result: " + s);
            System.out.println("throwable: " + throwable);
        }
    });

    // exceptionally对异常进行处理
    System.out.println("------------------------------");
    CompletableFuture.supplyAsync(() -> {
        throw new RuntimeException("Thread3 Failed.");
    }).whenComplete(new BiConsumer<Object, Throwable>() {
        @Override
        public void accept(Object s, Throwable throwable) {
            System.out.println("result: " + s);
            System.out.println("throwable: " + throwable);
        }
    });

    System.out.println("------------------------------");
    System.out.println("future.get(): " + future.get());

    // 主线程执行完毕
    System.out.println("------------------------------");
    System.out.println("Main Thread Finished.");
}

输出结果：

整理完毕，完结撒花~

以上就是Java8 CompletableFuture 异步执行的详细内容，更多关于Java8 CompletableFuture 异步执行的资料请关注脚本之家其它相关文章！

您可能感兴趣的文章:

相关文章

  • Java实现的不同图片居中剪裁生成同一尺寸缩略图功能示例

    Java实现的不同图片居中剪裁生成同一尺寸缩略图功能示例

    这篇文章主要介绍了Java实现的不同图片居中剪裁生成同一尺寸缩略图功能,涉及java针对图片的读取、属性修改等相关操作技巧,需要的朋友可以参考下
    2017-09-09
  • Java实现在Word中嵌入多媒体(视频、音频)文件

    Java实现在Word中嵌入多媒体(视频、音频)文件

    这篇文章主要介绍了Java如何实现在Word中嵌入多媒体(视频、音频)文件，文中的示例代码讲解详细，对我们学习java有一定的帮助，感兴趣的同学可以了解一下
    2021-12-12
  • Mybatis批量删除多表

    Mybatis批量删除多表

    MyBatis的作用我想不用多说，今天说说MyBatis中的批量删除操作。 需要的朋友一起看看吧
    2017-10-10
  • java读取配置文件自定义字段(yml、properties)

    java读取配置文件自定义字段(yml、properties)

    本文主要介绍了java读取配置文件自定义字段(yml、properties)，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
    2023-07-07
  • Java 处理超大数类型之BigInteger案例详解

    Java 处理超大数类型之BigInteger案例详解

    这篇文章主要介绍了Java 处理超大数类型之BigInteger案例详解,本篇文章通过简要的案例,讲解了该项技术的了解与使用,以下就是详细内容,需要的朋友可以参考下
    2021-09-09
  • springboot表单提交之validator校验

    springboot表单提交之validator校验

    在前台表单验证的时候，通常会校验一些数据的可行性，比如是否为空，长度，身份证，邮箱等等，这篇文章主要给大家介绍了关于springboot表单提交之validator校验的相关资料，需要的朋友可以参考下
    2021-05-05
  • MyBatis-Plus 实体类注解的实现示例

    MyBatis-Plus 实体类注解的实现示例

    MyBatis-Plus作为MyBatis的增强版,提供了一系列实用的注解,如@TableName、@TableId、@TableField等,旨在简化数据库和Java实体类之间的映射及CRUD操作,通过这些注解,开发者可以轻松实现表映射、字段映射、逻辑删除、自动填充和乐观锁等功能
    2024-09-09
  • zookeeper节点类型详解

    zookeeper节点类型详解

    今天小编就为大家分享一篇关于zookeeper节点类型详解，小编觉得内容挺不错的，现在分享给大家，具有很好的参考价值，需要的朋友一起跟随小编来看看吧
    2019-01-01
  • Java子类实例化总是默认调用父类的无参构造操作

    Java子类实例化总是默认调用父类的无参构造操作

    这篇文章主要介绍了Java子类实例化总是默认调用父类的无参构造操作，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
    2020-10-10
  • Java并发CopyOnWrite容器原理解析

    Java并发CopyOnWrite容器原理解析

    这篇文章主要介绍了Java并发CopyOnWrite容器原理解析,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-01-01

最新评论