锐客网

  1. 首页 > it技术 > >

Java并行流Stream多线程查询_list.stream().parallel()|Java并行流Stream多线程查询_list.stream().parallel() 并行流

https://blog.csdn.net/u011001723/article/details/52794455/：parallel()其实就是一个并行执行的流.它通过默认的ForkJoinPool,可能提高你的多线程任务的速度.
https://www.cnblogs.com/strivelearn/p/6005649.html：并发与并行的区别
Java 8 lambda stream forEach parallel 等循环与Java 7 for each 循环耗时测试: 转自：https://blog.csdn.net/qq_27093465/article/details/77770479
【Java并行流Stream多线程查询_list.stream().parallel()|Java并行流Stream多线程查询_list.stream().parallel() 并行流】Java 8 里面的stream 有串行流和并行流之分。
说高级的stream就是那个并行流。下面是那个并行流的简单实现。只要是继承Collection类的都可以这么用。
list.stream().parallel()
list.parallelStream()
package com.lxk.lambdaTest;
import com.google.common.collect.Lists;
import java.util.List;
/**
* 测试性能(Java 8 的循环和Java 7 的循环耗时的对比测试)
*
* Created by lxk on 2017/8/31
*/
public class Performance {
public static void main(String[] args) {
List list = getLoopList();
normalBeforeLoop(list);
normalAfterLoop(list);
notNormalAfterLoop(list);
}
private static void notNormalAfterLoop(List list) {
long a = System.currentTimeMillis();
list.stream().parallel().forEach(System.out::print);
System.out.println(" list.stream().parallel().forEach 执行耗时 : " + (System.currentTimeMillis() - a) / 1000f + " 秒 ");
}
private static void normalAfterLoop(List list) {
long a = System.currentTimeMillis();
list.stream().forEach(System.out::print);
System.out.println(" list.stream().forEach 执行耗时 : " + (System.currentTimeMillis() - a) / 1000f + " 秒 ");
a = System.currentTimeMillis();
list.forEach(System.out::print);
System.out.println(" list.forEach 执行耗时 : " + (System.currentTimeMillis() - a) / 1000f + " 秒 ");
}
private static void normalBeforeLoop(List list) {
long a = System.currentTimeMillis();
for (String s : list) {
System.out.print(s);
}
System.out.println(" for each 执行耗时 : " + (System.currentTimeMillis() - a) / 1000f + " 秒 ");
}
private static List getLoopList() {
List list = Lists.newArrayList();
for (int i = 0; i < 10000; i++) {
list.add("item " + i);
}
return list;
}
}
Java并行流Stream多线程查询_list.stream().parallel()|Java并行流Stream多线程查询_list.stream().parallel() 并行流
文章图片

好，关于，那个并行和串行的流的差别，可以看到啦。
并行的流，在循环的时候，就不是 1 - 9999 挨着输出。而是，看多核的心情。
Stream parallel并行流的思考
1.并行流并不一定能提高效率,就和多线程并不能提高线程的效率一样 因为引入并行流会引起额外的开销,就像线程的频繁上下文切换会导致额外的性能开销一样,当数据在多个cpu中的处理时间小于内核之间的传输时间 ...
jdk8系列三、jdk8之stream原理及流创建、排序、转换等处理
一.为什么需要 Stream Stream 作为 Java 8 的一大亮点,它与 java.io 包里的 InputStream 和 OutputStream 是完全不同的概念.它也不同于 StAX ...
jdk8--stream并行流
stream的并行流要理解一个框架如下: 单线程,多线程和并行流对比 package com.atguigu.java8; import java.util.concurrent.ForkJoinPo ...
java-11-Stream优化并行流
并行流多线程把一个内容分成多个数据块不同线程分别处理每个数据块的流串行流单线程一个线程处理所有数据java8 对并行流优化StreamAPI 通过pa ...
Stream的顺序流与并行流
/** * @auther hhh * @date 2019/1/2 22:52 * @description */ public class StreamAPI2 { /** * 流的特性:支持并行 ...
Stream01 定义、迭代、操作、惰性求值、创建流、并行流、收集器、stream运行机制
1 Stream Stream 是 Java 8 提供的一系列对可迭代元素处理的优化方案,使用 Stream 可以大大减少代码量,提高代码的可读性并且使代码更易并行. 2 迭代 2.1 需求 随机创建 ...
Fork/ Join框架与Java8 Stream API 之并行流的速度比较
Fork/Join 框架有特定的ExecutorService和线程池构成.ExecutorService可以运行任务,并且这个任务会被分解成较小的任务,它们从线程池中被fork(被不同的线程执行)出 ...
流API--使用并行流
这篇博客一起来研究下使用并行流.借组多核处理器并行执行代码可以显著提高性能,但是并行编程可能十分复杂且容易出错,流API提供的好处之一是能够轻松可靠的并行执行一些操作.请求并行处理流,首先要获得一个并 ...
Java8新特性 并行流与串行流 Fork Join
并行流就是把一个内容分成多个数据块,并用不同的线程分 别处理每个数据块的流. Java 8 中将并行进行了优化,我们可以很容易的对数据进行并 行操作. Stream API 可以声明性地通过 para ...
随机推荐
NOSDK--关于android傻瓜式的分包设想
一直以来,我总是以“够用就好”为理由,很少再维护过自己的一键打包的项目.最近接触了棱镜的sdk,感觉将apk包上传到棱镜服务器,后台来进行分包这种简单的方式很招人待见. 原理似乎不难,apk即zip压 ...
hdu 1530 最大团模板
说明摘自:pushing my way 的博文 最大团 通过该博主的代码,总算理解了最大团问题,但是他实现时的代码效率却不算太高.因此在最后献上我的模板.加了IO优化目前的排名是: 6 yejinru ...
Oracle11g导入* . dmp数据文件
imp命令导入数据:imp username/password@SID file=XXX.dmp fromuser=XXX touser=XXX tables=(XXX,XXX)[ignore=y ...
Servlet原理
Servlet主要用来处理客户端请求并将其结果发送到客户端,下面我们来详细看一下Servlet. 一.Servlet的生命周期 Servlet的生命周期是由Servlet的容器来控制的(Tomcat ...
input上传文件显示图片缩略图

    推荐阅读


    上一篇：灰狼算法|灰狼算法 c语言 代码,基于灰狼优化的模糊C—均值聚类算法

    下一篇：Java|Java8新特性(二) Stream（流）