当前位置：首页 > news >正文

Java 并行流（Parallel Stream）详解

news 来源：原创 2025/9/9 16:06:32

并行流是Java 8引入的高效处理集合数据的工具，通过多线程加速计算。以下是其核心概念、使用方法及注意事项的详细指南：

1. 核心概念与原理

并行处理机制：将数据分割为多个块，利用Fork/Join框架在多个线程上并行处理，最后合并结果。
默认线程池：使用ForkJoinPool.commonPool()，线程数等于CPU核心数（可通过系统参数调整）。
适用场景：大规模数据集、计算密集型任务（如数学运算、批量转换）。

2. 创建并行流的方式

直接生成：通过集合的parallelStream()方法。

转换顺序流：在现有流上调用parallel()。

List<Integer> list = Arrays.asList(1, 2, 3, 4);// 方式1：直接生成并行流
Stream<Integer> parallelStream1 = list.parallelStream();// 方式2：将顺序流转为并行
Stream<Integer> parallelStream2 = list.stream().parallel();

3. 适用场景与性能优化

推荐场景：
- 数据量大：如百万级元素的过滤、映射。
- 计算复杂：如矩阵运算、图像处理。
- 无状态操作：如map、filter、reduce（不依赖处理顺序或外部变量）。
性能陷阱：
- 小数据集：并行化开销（线程调度、数据分割）可能抵消收益。
- 低耗时操作：如简单加减法，并行可能更慢。

4. 注意事项与最佳实践

避免共享可变状态
并行操作中修改共享变量会导致线程安全问题，应使用无状态操作或同步控制。

// 错误示例：线程不安全的累加
List<Integer> nums = Arrays.asList(1, 2, 3);
int[] sum = {0};
nums.parallelStream().forEach(n -> sum += n); // 结果可能错误// 正确做法：使用归约
int safeSum = nums.parallelStream().reduce(0, Integer::sum);

谨慎使用有状态操作
如sorted()、distinct()在并行流中可能更耗时，需合并线程结果。

// 并行排序（可能比顺序流慢）
List<Integer> sortedList = nums.parallelStream().sorted().toList();

数据源的可拆分性
- 高效结构：ArrayList、数组（支持快速随机访问，易于分割）。
- 低效结构：LinkedList、TreeSet（拆分成本高）。

顺序敏感操作
使用forEachOrdered保证顺序，但牺牲性能。

// 按顺序输出（性能低于无序操作）
list.parallelStream().forEachOrdered(System.out::println);

配置线程池
- 默认线程数：Runtime.getRuntime().availableProcessors()。
- 修改全局线程数：
```
# JVM启动参数
-Djava.util.concurrent.ForkJoinPool.common.parallelism=8
```

5. 性能对比示例

// 顺序流 vs 并行流（处理1000万数据）
List<Long> numbers = LongStream.rangeClosed(1, 10_000_000).boxed().collect(Collectors.toList());// 顺序流耗时
long start = System.currentTimeMillis();
long seqSum = numbers.stream().mapToLong(n -> n * 2).sum();
System.out.println("顺序流耗时: " + (System.currentTimeMillis() - start) + "ms");// 并行流耗时
start = System.currentTimeMillis();
long parSum = numbers.parallelStream().mapToLong(n -> n * 2).sum();
System.out.println("并行流耗时: " + (System.currentTimeMillis() - start) + "ms");

典型结果（8核CPU）：

顺序流耗时: 120ms 并行流耗时: 35ms

6. 总结

优势：简化多线程编程，提升大数据处理效率。
局限：不适合小数据量、顺序敏感或低计算量任务。
最佳实践：
- 优先处理大规模数据。
- 避免操作共享变量。
- 测试验证性能提升。
- 使用forEach替代forEachOrdered除非必须保证顺序。

通过合理使用并行流，可在不增加复杂代码的情况下显著提升程序性能，但需结合场景权衡利弊。

Java 并行流（Parallel Stream）详解

并行流是Java 8引入的高效处理集合数据的工具，通过多线程加速计算。以下是其核心概念、使用方法及注意事项的详细指南： 1. 核心概念与原理并行处理机制：将数据分割为多个块，利用Fork/Join框架在多个线程上并行处理，…...

编程日记 2025/9/9 16:06:32

开源软件的版权保护措施

开源软件的版权保护措施主要有以下几方面： 著作权保护明确版权归属与许可使用：开源软件的源代码是著作权法保护的对象，作者享有复制权、发行权、改编权等专有权益。通过开源协议，作者明确授权用户使用、复制和修改软件&#xf…...

编程日记 2025/9/9 4:37:42

11.24 SpringMVC（1）@RequestMapping、@RestController、@RequestParam

一.RequestMapping("/user")//HTTP 请求方法既支持get也支持post，可表示为类路径与方法路径二.RequestMapping(value "/m7", method {RequestMethod.POST, RequestMethod.GET}) value这个参数指定了请求的 URL 路径。method 参数指定了允许…...

编程日记 2025/9/7 7:22:50

杰和科技GDSM-C数字化信息发布管理系统，信息触达无死角，更全面

在数字化时代，信息的高效传递与精准管理成为商业、教育、公共服务等领域的核心需求。传统信息发布模式常面临设备分散难管控、内容更新滞后、多屏协同效率低等问题。杰和科技为此开发了一套数字化信息发布管理系统GDSM-C（简称 GDSM-C）系统&a…...

编程日记 2025/9/9 18:18:27

一、停止 expdp job举例 1.执行 expdp 命令 $ expdp rui/rui DIRECTORYdmp_dir dumpfilestudyfull_expdp.dmp FULLy logfilestudyfullexpdp.log job_nameexpdp_job2.查看在运行的作业名称 SQL> select job_name,state from dba_datapump_jobs; JOB_NAME …...

编程日记 2025/9/8 12:20:26

Java 8 中，可以使用 Stream API 和 Comparator 对 List 按照元素对象的时间字段进行倒序排序

文章目录引言I 示例对象II List 按时间字段倒序排序: 使用 `Stream` 和 `Comparator` 排序方法 1：使用 `Comparator.comparing`方法 2：使用 `Comparator.reversed`方法 3：自定义 `Comparator`输出结果III 注意事项**时间字段类型**:**空值处理**:IV 总结引言案例：在线用…...

编程日记 2025/9/6 7:03:52

MySQL零基础教程14—子查询

子查询比较简单，我们还是通过案例引入。有时候我们查询的时候，需要用到的不止一个表的数据，比如下面的场景： 查询名字叫李晓红同学的班主任姓名我们提供三个表的基础信息如下： 从三张表的结构，我们不难…...

编程日记 2025/9/6 1:38:37

考研408数据结构线性表核心知识点与易错点详解（附真题示例与避坑指南）

一、线性表基础概念 1.1 定义与分类定义：线性表是由n（n≥0）个相同类型数据元素构成的有限序列，元素间呈线性关系。分类： 顺序表：元素按逻辑顺序存储在一段连续的物理空间中（数组实现&…...

编程日记 2025/9/8 15:07:39

Microk8s Ingress实现七层负载均衡

Microk8s Ingress是什么 Ingress是k8s的一种资源对象，用于管理外部对集群内服务的访问, 它通过提供一个统一的入口点，将外部流量路由到集群内部的不同服务。 Microk8s Ingress用于解决什么问题 k8s集群中服务默认只能在集群内访问。如果需要从外部访…...

编程日记 2025/9/7 15:36:32

部署Windows Server自带“工作文件夹”实现企业网盘功能完整步骤

前文已经讲解过Windows Server自带的“工作文件夹”功能，现以Windows Server 2025为例介绍部署工作文件夹的完整步骤： 为了确保您能够顺利部署和充分利用工作文件夹的功能，我将按照以下步骤进行讲解。请注意，在域环境中部署工作…...

编程日记 2025/9/2 13:25:00

前缀和算法算法4

算法题中帮助复习的知识 vector<int > dp( n ,k); n为数组大小 ,k为初始化哈希表unordered_map<int ,int > hash; hash.find(k)返回值是迭代器 ,找到k返回其迭代器没找到返回hash.end() hash.count(k)返回值是数字 ,找到k返回1 ,没找到返回0. C和java中负数…...

编程日记 2025/9/6 20:43:01

Excel 豆知识 - XLOOKUP 为啥会出 #N/A 错误

XLOOKUP有的时候会出 #VALUE! 这个错误。因为这个XLOOUP有个参数叫找不到时的返回值，那么为啥还会返回 #VALUE! 呢？ 可能还有别的原因，但是主要原因应该就是检索范围和返回范围不同。比如这里检索范围在 B列，是 4-21&…...

编程日记 2025/8/16 12:39:11

ZK Rollup

ZK Rollup 通过生成零知识证明来确保所有提交的交易都是有效的。生成零知识证明的过程涉及复杂的密码学运算，通常使用的是 zk-SNARK（零知识简洁非互动知识论证）或 zk-STARK（零知识可扩展透明知识论证）。以下是 ZK Roll…...

编程日记 2025/9/7 8:40:10

UI设计——新拟态手机主题锁屏设计分享

新拟态手机主题锁屏设计分享给大家展示一款新式手机主题锁屏设计作品。整体设计采用简洁的灰白主色调，搭配亮眼的橙色元素，形成鲜明对比，视觉效果清爽又不失活力。上方显示大数字时钟 “20:36”，日期 “04/11 星期一” 以及天…...

编程日记 2025/9/5 7:59:31

Kafka面试题及原理

1. 消息可靠性（不丢失） 使用Kafka在消息的收发过程都会出现消息丢失，Kafka分别给出了解决方案生产者发送消息到Brocker丢失消息在Brocker中存储丢失消费者从Brocker 幂等方案：【分布式锁、数据库锁（悲观锁、乐观锁…...

编程日记 2025/8/29 2:57:59

leetcode 238. 除自身以外数组的乘积

题目如下数据范围使用两个辅助数组分别存从前乘到后面和从后到前后面再计算就行。 （f数组没处理好还包含了本不能乘于的数所以要向后移动一位）。通过代码 class Solution { public:vector<int> productExceptSelf(vector<int>& n…...

编程日记 2025/9/8 10:31:44

DeepSeek 与 ChatGPT 终极对决：谁才是 AI 语言之王？

我的个人主页我的专栏：人工智能领域、java-数据结构、Javase、C语言，希望能帮助到大家！！！点赞👍收藏❤ 引言在当今科技飞速发展的时代，人工智能已然成为推动各领域变革的核心力量&#xff…...

编程日记 2025/9/7 22:14:03

python爬虫：pyspider的详细使用

文章目录一、pyspider介绍1.1 核心概念1.2 与其他爬虫框架的比较二、安装 pyspider三、编写爬虫脚本四、运行和监控爬虫4.1 启动爬虫4.2 监控任务状态4.3 任务管理五、高级功能5.1 分布式爬取5.2 JavaScript 渲染5.3 数据存储5.4 定时任务5.5 错误处理和重试机制六、示例：采…...

编程日记 2025/9/5 19:36:07

CSS—text文本、font字体、列表list、表格table、表单input、下拉菜单select

目录 1.文本 2.字体 3.列表list a.无序列表 b.有序列表 c.定义列表 4.表格table a.内容 b.合并单元格 3.表单input a.input标签 b.单选框 c.上传文件 4.下拉菜单 1.文本属性描述color设置文本颜色。direction指定文本的方向 / 书写方向。letter-spacing设置字符…...

编程日记 2025/9/8 22:21:34

宝塔webhooks与码云实现自动部署

1. 宝塔面板配置Webhook 登录宝塔面板，进入「软件商店」→ 搜索「Webhook」并安装。添加Webhook： 名称：自定义（如 Gitee自动部署）脚本：编写部署脚本，示例如下：#!/bin/bash# 项目路径…...

编程日记 2025/9/4 9:58:03

迷你世界脚本聊天接口：Chat

聊天接口：Chat 彼得兔更新时间: 2023-04-26 10:18:43 具体函数名及描述如下: 序号函数名函数描述 1 sendChat(...) 发送聊天消息(默认全部玩家) 2 sendSystemMsg(...) 发送系统消息(默认全部玩家) sendChat 参数及类型： content:s…...

编程日记 2025/9/5 13:55:43

Yocto + 树莓派摄像头驱动完整指南

—— 从驱动配置、Yocto 构建，到 OpenCV 实战在树莓派上运行摄像头，在官方的 Raspberry Pi OS 可能很简单，但在 Yocto 项目中，需要手动配置驱动、设备树、软件依赖才能确保摄像头正常工作。本篇文章从 BSP 驱动配置、Yocto 关键…...

编程日记 2025/8/16 13:00:02

多镜头视频生成、机器人抓取、扩散模型个性化 | Big Model weekly第58期

点击蓝字关注我们 AI TIME欢迎每一位AI爱好者的加入！ 01 GLM-4-Voice: Towards Intelligent and Human-Like End-to-End Spoken Chatbot 本文介绍了一种名为GLM-4-Voice的智能且类人化的端到端语音聊天机器人。它支持中文和英文，能够进行实时语音对话&a…...

编程日记 2025/9/5 9:48:55

Llama 2中的Margin Loss：为何更高的Margin导致更大的Loss和梯度？

Llama 2中的Margin Loss：为何更高的Margin导致更大的Loss和梯度？ 在《Llama 2: Open Foundation and Fine-Tuned Chat Models》论文中，作者在强化学习与人类反馈（RLHF）的Reward Model训练中引入了Margin Loss的概念&a…...

编程日记 2025/9/3 12:51:26

边缘计算收益低的三大指标

边缘计算收益低的三大指标主要包括以下方面： 1. 资源贡献不足： 边缘计算的收益通常基于所提供的带宽、存储和计算资源来计算。如果设备的网络带宽有限、在线时间短或提供的存储容量较小，可能无法满足平台设定的最低贡献标准，从而导…...

编程日记 2025/9/2 1:19:34

基于单片机的智能宿舍管理系统（论文+源码）

2.1总体方案设计本课题为智能宿舍的设计，整个系统架构如图2.1所示，整个系统在器件上包括了主控制器STM32单片机，LD3320语音识别模块，按键模块，串口通信模块，照明模块，窗帘控制模块家电控制模块…...

编程日记 2025/9/6 19:20:33

（下：补充——五个模型的理论基础）深度学习——图像分类篇章

目录 1.1 卷积神经网络基础 3.1 AlexNet网络结构详解与花分类数据集下载 4.1 VGG网络详解及感受野的计算 5.1 GoogLeNet网络详解 6.1 ResNet网络结构，BN以及迁移学习详解总结（可以直接看总结） 1.1 卷积神经网络基础视频讲解&#xf…...

编程日记 2025/9/7 5:19:57

SVN 简介

SVN 简介引言版本控制系统（Version Control System，VCS）是软件开发过程中不可或缺的工具之一。它能够帮助开发者管理代码的版本，追踪代码变更，协同工作，以及确保代码的稳定性和安全性。Subversion（简称SVN）是一种流行的版本控制系统，本文将为您详细介绍SVN的基本概…...

编程日记 2025/9/4 19:58:58

【前端场景题】如何应对页面请求接口的大规模并发问题

如何应对页面请求接口的大规模并发问题，尤其是前端方面的解决方案，并且需要给出详细的代码解释。首先，我需要仔细阅读我搜索到的资料，找出相关的信息，然后综合这些信息来形成答案。首先看，它提到前端优化策…...

编程日记 2025/9/9 15:05:35

Kafka 为什么会消息堆积？

Kafka 定期清理 Partition，但消息堆积（backlog） 依然可能发生，主要是因为 Kafka 的清理机制和消息消费进度是两回事。我们可以用一个快递仓库的类比来解释。类比：Kafka 就像一个快递仓库生产者（Produc…...

编程日记 2025/9/9 8:54:09

毕业项目推荐：基于yolov8/yolo11的苹果叶片病害检测识别系统（python+卷积神经网络）

文章目录概要一、整体资源介绍技术要点功能展示：功能1 支持单张图片识别功能2 支持遍历文件夹识别功能3 支持识别视频文件功能4 支持摄像头识别功能5 支持结果文件导出（xls格式）功能6 支持切换检测到的目标查看二、数据集三、算法介绍1. YO…...

编程日记 2025/8/20 11:47:55

十四届蓝桥杯JAVA-b组-合并石子

点我写题思路：区间dp和缝合dp板子题，先用个dp[i][j][k]表示考虑区间[i,j]合并成颜色k的最小代价，然后用min[i][j]存一下[i,j]区间合并的最小代价，即min(dp[i][j][0-2])，has[i][j]表示区间[i,j]是否能合并&#xff0c…...

编程日记 2025/9/1 17:51:59

【Maven】入门介绍与安装、配置

文章目录一、Maven简介1. Maven介绍2. Maven软件工作原理模型图二、Maven安装和配置1. Maven安装2. Maven环境配置3. Maven功能配置4. IDEA配置本地Maven软件一、Maven简介 1. Maven介绍 https://maven.apache.org/what-is-maven.html Maven 是一款为 Java 项目管理构建、…...

编程日记 2025/9/5 21:46:13

物联网小范围高精度GPS使用

在园区内实现小范围高精度GPS（全球定位系统）定位，通常需要结合多种技术来弥补传统GPS在精度和覆盖范围上的不足。以下是实现小范围高精度GPS定位的解决方案，包括技术选择、系统设计和应用场景。一、技术选择在园区内实现高精度…...

编程日记 2025/9/8 1:42:58

突破Ajax跨域困境，解锁前端通信新姿势

一、引言在当今的 Web 开发领域，前后端分离的架构模式已经成为主流，它极大地提升了开发效率和项目的可维护性。在这种开发模式下，前端通过 Ajax 技术与后端进行数据交互，然而，跨域问题却如影随形，成为了开…...

编程日记 2025/9/4 20:16:14

Docker 学习（一）

一、Docker 核心概念 Docker 是一个开源的容器化平台，允许开发者将应用及其所有依赖（代码、运行时、系统工具、库等）打包成一个轻量级、可移植的“容器”，实现 “一次构建，随处运行”。 1、容器（Container…...

编程日记 2025/9/3 15:58:12

【漫话机器学习系列】111.指数之和的对数（Log-Sum-Exp）

在计算机科学和机器学习中，经常会遇到计算指数和的对数的情况，例如： 然而，由于指数函数的值增长极快，直接计算可能会导致数值上溢（overflow）或下溢（underflow）&#xf…...

编程日记 2025/9/1 3:29:20

算法004——盛最多水的容器

力扣——盛最多水的容器点击即可跳转当我们选择1号线和8号线时，下标为 1 和 8 形成容器的容积的高度是由较矮的决定的，即下标为 8 的位置； 而宽度则是 1到8 之间的距离，为 8-17，此时容器的容积为 7 * 7 49。当我…...

编程日记 2025/9/8 19:28:43

前端内存泄漏的几种情况及方案

前端内存泄漏是常见但容易被忽视的问题，可能导致页面卡顿、崩溃或性能下降。以下是几种典型场景及解决方案： 1. 未清理的全局变量场景： 意外创建全局变量（未使用 var/let/const）。主动挂载到 window 的大对象未释放…...

编程日记 2025/9/3 21:54:37

14. LangChain项目实战1——基于公司制度RAG回答机器人

教学视频： 12. 基于Gradio搭建基于公司制度RAG_哔哩哔哩_bilibilihttps://www.bilibili.com/video/BV11VXRYTErZ/ 环境配置： python版本：3.10.8 服务器：Ubuntu 依赖包requirements.txt文件内容： aiofiles23.2.1 …...

编程日记 2025/9/4 6:48:23

解锁 indexOf、substring 和 JSON.stringify：从小程序图片上传看字符串魔法 ✨

🌟 解锁 indexOf、substring 和 JSON.stringify：从小程序图片上传看字符串魔法 ✨ 在 JavaScript 中，字符串操作和数据序列化是开发中不可或缺的技能。indexOf、substring 和 JSON.stringify 是三个简单却强大的工具，分别用于定位…...

编程日记 2025/9/8 12:50:28

Git快速入门

文章目录 Git简介准备工作常用的Linux命令git配置 git工作原理git项目创建和克隆git基本操作命令git忽略文件配置ssh远程连接 IDEA集成Gitgit分支（多人开发）公司中用到的（很清楚） Git 简介 Git就是版本控制的工具下面这个叫手动…...

编程日记 2025/9/7 9:45:30

老牌工具，16年依然抗打！

在电脑还没普及、操作系统为Windows XP/7的时代，多媒体文件的转换操作常常面临格式不兼容的问题。这时一款名为格式工厂的软件成为了众多用户的首选工具。格式工厂以其简洁易用的界面和强大的功能，轻松地进行各种文件格式的转换。成为很多修小伙伴的喜爱…...

编程日记 2025/9/6 20:47:29

JavaScript 进阶A（作用域、闭包、变量和函数提升、函数相关只是、数组解构、对象解构、构造函数

1.作用域作用域主要分为：局部作用域和全局作用域。局部作用域又分为：函数作用域和块作用域函数作用域：在函数中定义的变量只能在函数内部使用，外部无法访问块作用域：被大括号{}包起来的代码块，在这个…...

编程日记 2025/9/5 9:22:10

《深度剖析：特征工程—机器学习的隐秘基石》

在机器学习的宏大版图中，特征工程宛如一座隐藏在幕后却又至关重要的基石。它默默发挥着作用，将原始数据雕琢成模型能够有效学习和理解的形态，深刻影响着机器学习模型的性能与表现。特征工程：机器学习的关键前奏特征工程是运用…...

编程日记 2025/9/8 6:24:36

Python Tornado 框架面试题及参考答案

目录 Tornado 框架的核心组件是什么？解释其作用。 Tornado 与其他 Python 框架（如 Django、Flask）的主要区别是什么？为什么 Tornado 适合高并发场景？其设计哲学是什么？解释 Tornado 的 Application 类和 RequestHandler 类的关系。如何在 Tornado 中配置静态文件路…...

编程日记 2025/9/4 7:03:11

【音视频】VLC播放器

提示：文章写完后，目录可以自动生成，如何生成可参考右边的帮助文档一、vlc是什么？ VLC Media Player（简称VLC）是一款免费、开源、跨平台的多媒体播放器，由非营利组织VideoLAN开发，最…...

编程日记 2025/9/9 6:07:10

视觉图像坐标转换

1. 透镜成像相机的镜头系统将三维场景中的光线聚焦到一个平面（即传感器）。这个过程可以用小孔成像模型来近似描述，尽管实际相机使用复杂的透镜系统来减少畸变和提高成像质量。小孔成像模型： 假设有一个理想的小孔，…...

编程日记 2025/9/4 13:13:51

算法刷题-2025年03月01日

import java.util.ArrayList; import java.util.Arrays; import java.util.List;public class test_02_28 {//长度最小的子数组找出总和大于等于target的长度最小的子数组//target 7, nums [2,3,1,2,4,3] [1.2.2.3.3.4]public static int test1(int[] nums, int target){//存…...

编程日记 2025/9/8 22:37:05

算法1-2 分数线划定

题目描述世博会志愿者的选拔工作正在 A 市如火如荼的进行。为了选拔最合适的人才，A 市对所有报名的选手进行了笔试，笔试分数达到面试分数线的选手方可进入面试。面试分数线根据计划录取人数的 150% 划定，即如果计划录取 m 名志愿者&#xf…...

编程日记 2025/9/7 18:48:48