parallel stream-不能随便使用
2024-09-07 18:25:54
前言
java8除了新增stream，还提供了parallel stream-多线程版的stream，parallel stream的优势是:充分利用多线程,提高程序运行效率,但是正确的使用并不简单,盲目使用可能导致以下后果
- 效率不增反降
- 增加额外的复杂度,程序更易出错
- 运行结果不正确
效率不增反降
parallel stream是基于fork/join框架的,简单点说就是使用多线程来完成的,使用parallel stream时要考虑初始化fork/join框架的时间,如果要执行的任务很简单,那么初始化fork/join框架的时间会远多于执行任务所需时间,也就导致了效率的降低.
根据附录doug Lee的说明,任务数量*执行方法的行数>=10000或者执行的是消耗大量时间操作(如io/数据库)才有必要使用
增加额外的复杂度,程序更易出错
在spring框架中,假设有一组主键id,使用这组id去数据库获取记录
//DB.fetchRecord(long id)使用当前线程session连接数据库
ids.parallelStream().map(DB::fetchRecord).collect(Collections.toList());
这里使用parallel stream是正确的,但是运行会报错,类似于 can't obtain session from current thread.原因就是多线程运行,对应的线程没有绑定的session,要完成上面的功能需要提供一个特殊版本的DB方法
//不从线程获取session,而是在方法内部开启新的session
DB.fetchRecordWithoutSession(long id)
运行结果不正确
还是以上面的例子,session问题已经解决,如果获取到的记录需要和ids顺序相同,那么使用parallel获取到的结果就是不正确的,原因还是多线程
如何正确使用:
- 确保要执行的任务对线程环境没有依赖
- 任务消耗时间长/数据量大到不用思考是否要用parallel
- 结果没有顺序要求
最新文章
- CF451A Game With Sticks 水题
- RRD
- 使用POI来实现对Excel的读写操作
- Machine Learning/Introducing Logistic Function
- php实现人员的权限管理
- BZOJ3032 七夕祭
- SAS 选取部分观测
- Codeforces986C AND Graph 【位运算】【dfs】
- 随机函数rand()和srand()
- 51Nod - 1384 正常解法
- swift 需求： 导航栏和HeaderView 使用一个背景图片。
- 自己对Java的一些认识
- ubuntu: apt-get update的时候遇到“Hash Sum mismatch”错误
- Log4j基础知识
- JAVA内部线程1
- C++ Boost在Windows和Linux下的编译安装
- linux ln链接详解
- PAT——1057. 数零壹
- Leetcode-Permuation Sequence
- js原型链继承及调用父类方法