CompletableFuture与并行流parallel()实

前言

  并发编程是编程中最棘手最难处理的痛点，任何一种优秀的语言都不可避免对并发编程的支持。Java1.8版本推出了流式编程，其中的并行流可以让开发者在流后添加一个parallel方法就实现并发编程；另外，1.8中对异步支持的CompletableFuture配上线程池同样可以实现并发，那我们就来探讨一下这两种方式实现并发的使用场景及优缺点。

实现并发对比

  这两种方式中使用并行流最简单只需要一行代码，其缺点就是默认线程数为当前计算机核数，可通过（Runtime.getRuntime().availableProcessors()查看，我的是8），我们来验证一下，为了更好的体现并发，我们这边先写一个方法用于并发执行，就是简单的一个线程阻塞，如下：

    /**
     * @return
     */
    private int delayMethod() {
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        return 1;
    }

**首先使用并行流来实现并发执行8次该方法，我们打印出执行时间：

       long start = System.currentTimeMillis();
       //IntStream.rangeClosed方法就是产生1到8整数，parallel为并行产生
        IntStream.rangeClosed(1, 8).parallel().mapToObj(i ->delayMethod()
        ).collect(Collectors.toList());//使用collect将所有结果收集起来，保证8个线程都执行完成再进入下一行打印
        System.out.println(System.currentTimeMillis() - start);

执行结果如下：

执行结果.png

有一点延时，但确实是1秒的结果，接下来将并行执行1到9来看看结果：

执行结果.png
不出所料，第九个只能等到下一轮执行了，所有需要两秒。
**接下来看一看我们使用CompletableFuture实现

        long start = System.currentTimeMillis();
        IntStream.rangeClosed(1, 8)
                //异步执行
                .mapToObj(i -> CompletableFuture.supplyAsync(CompeleteFuture::delayMethod))
              //收集future
                .collect(Collectors.toList())
                .stream()
              //并行获取
                .map(CompletableFuture::join)
                .collect(Collectors.toList());
        System.out.println(System.currentTimeMillis() - start);

  这里如果有看不懂CompletableFuture使用的小伙伴可以看上一篇https://www.jianshu.com/p/dc5aed227d5c，执行结果如下：

执行结果.png
  怎么回事，竟然是两秒，哈哈，翻车了！其实应该是CompletableFuture默认线程是7吧，换成7就是一秒了，这里就说到CompletableFuture的优点了，它可以对线程执行器进行配置改变线程数，比并行流灵活性高！我们来试一下，配置如下 执行结果.png
这次的执行结果就对啦，再增大线程数到20，并发数也改20看看：
配置线程个数为20执行器执行结果.png

怎么样，是不是很舒服这个结果，哈哈哈！

使用并行流还是CompletableFuture？

建议：

• 如果进行的是计算机密集型的操作，并且没有IO，那么推荐使用Stream接口，因为实现简单，同时效率也可能是最高的（如果所有线程都是计算秘籍型的，那就没有必要创建比处理器核数更多的线程）
• 反之，如果你并行的工作单元涉及I/O的操作（包括网络连接等）那么使用CompletableFuture灵活性更好。

参考

• 《Java8实战》