前言

并发编程是编程中最棘手最难处理的痛点，任何一种优秀的语言都不可避免对并发编程的支持。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，执行结果如下：