Java多线程：线程池与CompletableFuture异步编排

浅浅的花香味﹌ 2022-11-12 09:45 229阅读 0赞

### 文章目录 ###

*  1. 线程池
 *  2. CompletableFuture
 *   *  2.1 异步任务创建执行
     *   *  2.1.1 supplyAsync / runAsync
     *  2.2 异步回调
     *   *  2.2.1 thenApply / thenApplyAsync
         *  2.2.2 thenAccept / thenRun

# 1. 线程池 #

通常的线程池接口类ExecutorService  
（1）execute方法的返回值是void，无法获取异步任务的执行状态  
（2）submit方法的返回值是Future，可以据此获取任务执行的状态和结果。子线程执行异常时其异常会被捕获，然后修改任务的状态为异常结束并唤醒等待的主线程，get方法判断任务状态发生变更，就终止等待了，并抛出异常

# 2. CompletableFuture #

## 2.1 异步任务创建执行 ##

### 2.1.1 supplyAsync / runAsync ###

1.  supplyAsync会带有返回值，类似ExecutorService的submit  
    举例

@RequestMapping("/supplyAsync")
        public String myTest3() throws ExecutionException, InterruptedException {
            System.out.println("111111111111111111");
            CompletableFuture<String> stringCompletableFuture = CompletableFuture.supplyAsync(() -> {
                System.out.println("当前线程:>> " + Thread.currentThread().getName());
                System.out.println("2222222222222222222");
                return "testThread3";
            }, asyncServiceExecutor);
            System.out.println("33333333333333333333");
            System.out.println("线程执行完毕：>> " + stringCompletableFuture.get());
            return stringCompletableFuture.get();
        }

1.  runAsync没有返回值，类似ExecutorService的execute

@RequestMapping("/runAsync")
        public String myTest4() {
            System.out.println("111111111111111111");
            CompletableFuture.runAsync(() -> {
                System.out.println("当前线程:>> " + Thread.currentThread().getName());
                System.out.println("2222222222222222222");
            });
            System.out.println("33333333333333333333");
            return "OK";
        }

1.  注意： 这两方法各有一个重载版本，可以指定执行异步任务的Executor实现，如果不指定，默认使用ForkJoinPool.commonPool()，如果机器是单核的，则默认使用ThreadPerTaskExecutor，该类是一个内部类，每次执行execute都会创建一个新线程

## 2.2 异步回调 ##

### 2.2.1 thenApply / thenApplyAsync ###

1.  thenApply：表示某个任务执行完成后执行的动作，即回调方法。会将该任务的执行结果（方法的返回值）作为入参传递到回调方法中。测试用例如下：

@RequestMapping("/thenApply")
        public Integer myTest5() throws ExecutionException, InterruptedException { 
            CompletableFuture<Integer> integerCompletableFuture = CompletableFuture.supplyAsync(() -> { 
                System.out.println("异步任务1开始。。。。");
                try { 
                    Thread.sleep(3000);
                } catch (InterruptedException e) { 
                    e.printStackTrace();
                }
                System.out.println("异步任务1结束。。。。");
                return 250;
            });
            CompletableFuture<Integer> integerCompletableFuture1 = integerCompletableFuture.thenApply(result -> { 
                System.out.println("异步任务2开始。。。。");
                try { 
                    Thread.sleep(3000);
                } catch (InterruptedException e) { 
                    e.printStackTrace();
                }
                System.out.println("异步任务2结束。。。。");
                return result + 300;
            });
            System.out.println("主线程执行结束。。。。");
            return integerCompletableFuture1.get();

最终返回：550

1.  thenApplyAsync：
    
    thenApplyAsync与thenApply的区别在于：thenApplyAsync是将任务2提交到线程池中异步执行，实际执行任务2的线程可能是另外一个线程，thenApply是由执行任务1的线程立即执行任务2，即两个任务都是同一个线程执行的。
2.  注意：thenApplyAsync有一个重载版本，可以指定执行异步任务的Executor实现，如果不指定，默认使用ForkJoinPool.commonPool()

下述的多个方法，每个方法都有两个以Async结尾的方法，一个使用默认的Executor实现，一个使用指定的Executor实现，不带Async的方法是由触发该任务的线程执行该任务，带Async的方法是由触发该任务的线程将任务提交到线程池，执行任务的线程跟触发任务的线程不一定是同一个

### 2.2.2 thenAccept / thenRun ###

1.  thenAccept ：thenApply 接收上一个任务的返回值作为参数，但是无返回值；
2.  thenRun：方法没有入参，也没有返回值

原文地址：[https://blog.csdn.net/qq\_31865983/article/details/106137777][https_blog.csdn.net_qq_31865983_article_details_106137777]

[https_blog.csdn.net_qq_31865983_article_details_106137777]: https://blog.csdn.net/qq_31865983/article/details/106137777