前言
并发编程是编程中最棘手最难处理的痛点，任何一种优秀的语言都不可避免对并发编程的支持。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实战》
