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

Java中parallelStream并行流使用指南

news 来源：原创 2025/9/12 11:55:45

Java中parallelStream并行流使用指南

在 Java 中，parallelStream() 是 Java 8 引入的一个用于并行处理集合数据的工具，它基于 Fork/Join框架实现，能够自动将任务拆分成子任务并利用多核处理器并行执行。以下是对 parallelStream的详细说明和注意事项：

1. 基本用法

parallelStream() 是 Collection接口的默认方法，可以直接调用：

List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5);// 使用 parallelStream 并行处理
long count = numbers.parallelStream().filter(n -> n % 2 == 0).count();

2. 并行流 vs 顺序流

顺序流 (stream())：单线程按顺序处理数据。
并行流 (parallelStream())：数据被分成多个块，并行处理后合并结果。

3. 注意事项

(1) 线程安全问题

并行流的操作（如 forEach、reduce）可能涉及多线程，需确保共享变量是线程安全的。

// 错误示例：非线程安全的累加
List<Integer> unsafeList = new ArrayList<>();
numbers.parallelStream().forEach(unsafeList::add); // 可能导致数据丢失或异常// 正确做法：使用线程安全的收集器
List<Integer> safeList = numbers.parallelStream().collect(Collectors.toList());

(2) 避免有状态操作

如果操作依赖顺序或共享状态（如 sorted()、limit()），并行可能降低性能或导致错误。

// sorted() 在并行流中可能效率更低
numbers.parallelStream().sorted().forEach(...);

(3) 性能考量

数据量小：并行化可能因线程调度开销而更慢。
任务复杂度高：适合计算密集型任务（如复杂数学运算）。
避免阻塞操作：如 I/O 操作会浪费线程资源。

(4) 默认线程池

并行流使用 ForkJoinPool.commonPool()（默认线程数 = CPU 核心数）。
可通过系统属性调整默认线程池：

System.setProperty("java.util.concurrent.ForkJoinPool.common.parallelism", "8");

4. 适用场景

大规模数据集处理（如过滤、映射、归约）。
独立计算任务（无共享状态或顺序依赖）。
计算密集型操作（如数学计算、加密等）。

5. 示例

(1) 并行求和

int sum = numbers.parallelStream().mapToInt(Integer::intValue).sum();

(2) 并行过滤

List<Integer> evenNumbers = numbers.parallelStream().filter(n -> n % 2 == 0).collect(Collectors.toList());

(3) 自定义线程池（Java 8+）

ForkJoinPool customPool = new ForkJoinPool(4);
customPool.submit(() -> numbers.parallelStream().forEach(n -> process(n))
).get();

6. 总结

优势：简化并行编程，提升多核 CPU 利用率。
劣势：滥用可能导致线程安全问题、性能下降。
原则：优先使用顺序流，仅在必要时（数据量大、任务独立）使用并行流。

Java中parallelStream并行流使用指南

Java中parallelStream并行流使用指南在 Java 中，parallelStream() 是 Java 8 引入的一个用于并行处理集合数据的工具，它基于 Fork/Join框架实现，能够自动将任务拆分成子任务并利用多核处理器并行执行。以下是对 parallelStream的详细说明和…...

编程日记 2025/9/12 11:55:45

Python及C++中的列表

一、Python中的列表（List） Python的列表是动态数组，内置于语言中，功能强大且易用，非常适合算法竞赛。 1. 基本概念定义：列表是一个有序、可变的序列，可以存储任意类型的元素（整数…...

编程日记 2025/9/9 15:01:22

mybatis plus 分页查询出来数据后对他二次修改数据封装返回

mybatis plus 分页查询出来数据后对他二次修改数据封装返回 /*** 搜索问卷** param keyword* param pageNo* param pageSize* return*/AutoLog(value "v_survey-搜索")ApiOperation(value"v_survey-搜索", notes"v_survey-搜索")GetMapping(v…...

编程日记 2025/9/12 11:54:55

海洋大地测量基准与水下导航系列之八我国海洋水下定位装备发展现状

中国国家综合PNT体系建设重点可概括为“51N”，“5”指5大基础设施，包括重点推进下一代北斗卫星导航系统、积极发展低轨导航增强系统、按需发展水下导航系统、大力发展惯性导航系统、积极探索脉冲星导航系统；“1”是实现1个融合发展&#xff0…...

编程日记 2025/8/17 21:32:11

基于单片机的电梯智能识别电动车阻车系统设计与实现

标题:基于单片机的电梯智能识别电动车阻车系统设计与实现内容:1.摘要随着电动车在日常生活中的普及，将电动车带入电梯带来的安全隐患日益凸显，如引发火灾等。本研究的目的是设计并实现一种基于单片机的电梯智能识别电动车阻车系统。方法上&#xff0c…...

编程日记 2025/9/12 11:55:45

什么是柜台债

柜台债（柜台债券业务）是指通过银行等金融机构的营业网点或电子渠道，为投资者提供债券买卖、托管、结算等服务的业务模式。它允许个人、企业及机构投资者直接参与银行间债券市场的交易，打破了以往仅限机构参与的壁垒。以下是综合多…...

编程日记 2025/8/27 15:29:23

.py文件和.ipynb文件的区别：完整教程

一、概述 Python开发者常用的两种文件格式.py和.ipynb各有特点，本教程将通过对比分析、代码示例和场景说明，帮助开发者全面理解二者的区别与联系。二、核心区别对比 1. 文件格式本质特性.ipynb文件.py文件文件类型JSON结构化文档纯文本文件存储内容…...

编程日记 2025/9/2 19:56:27

Python中NumPy的逻辑和比较

在数据科学和科学计算领域，NumPy是一个不可或缺的Python库。它提供了高效的多维数组对象以及丰富的数组操作函数，其中逻辑和比较操作是NumPy的核心功能之一。通过灵活运用这些操作，我们可以轻松实现数据筛选、条件判断和复杂的数据处理任务。…...

编程日记 2025/8/17 19:45:23

tt_Docker

快速上手查看 Docker 服务运行状态;查看本地镜像;从 Docker Hub 拉取基础镜像, 我们此处选择 ubuntu:18.04 镜像;再次查看本地镜像;使用 ubuntu:18.04 镜像构建容器，并交互式运行容器；在容器内部执行 LS 命令;退出容器;查看本地容器实例;再次启动停止的…...

编程日记 2025/8/24 15:01:16

虚幻引擎5-Unreal Engine笔记之“将MyStudent变量设置为一个BP_Student的实例”这句话如何理解？

虚幻引擎5-Unreal Engine笔记之“将MyStudent变量设置为一个BP_Student的实例”这句话如何理解？ code review! 文章目录虚幻引擎5-Unreal Engine笔记之“将MyStudent变量设置为一个BP_Student的实例”这句话如何理解？理解这句话的关键点1.类&#xff08…...

编程日记 2025/8/20 8:52:48

compose map 源码解析

目录 TileCanvas ZoomPanRotateState ZoomPanRotate 布局,手势处理完了,就开始要计算tile了 MapState TileCanvasState telephoto的源码已经分析过了.它的封装好,扩展好,适用于各种view. 最近又看到一个用compose写的map,用不同的方式,有点意思.分析一下它的实现流程与原…...

编程日记 2025/9/7 8:43:30

IDEA202403 常用设置【持续更新】

文章目录 1、设置maven2、设置JDK3、菜单栏固定展示4、连接Gitee第一步、安装插件第二步、Gitee账号配置 IDEA 是程序员的编程利器，需要具备其的各种配置，提高工作效率。Java项目启动，两个关键设置：Maven 和 JDK设置。 1、设置mav…...

编程日记 2025/9/7 22:16:06

从零开始开发纯血鸿蒙应用之语音输入

从零开始开发纯血鸿蒙应用〇、前言一、认识 speechRecognizer1、使用方式2、依赖权限3、结果回写二、实现语音识别功能1、创建语音识别引擎2、设置事件监听3、启动识别4、写入音频数据5、操作控制三、总结〇、前言除了从图片中识别文本外，语音输入也是一种现代…...

编程日记 2025/9/5 12:41:24

c++ STL常用工具的整理和思考

蓝桥杯后，我整理了这些常用的C STL工具作为一个算法竞赛的中等生，以前总觉得STL“花里胡哨”，不如自己写数组和循环踏实。但这次蓝桥杯发现，合理用STL能省很多时间，甚至避免低级错误。下面是我总结的常用知识点和踩过…...

编程日记 2025/9/10 1:26:16

Go：复合数据结构

数组定义：数组是固定长度、元素数据类型相同的序列。元素通过索引访问，索引从 0 到数组长度减 1 。可用len函数获取元素个数。初始化：默认元素初始值为类型零值（数字为 0 ） 。可使用数组字面量初始化，…...

编程日记 2025/9/6 11:31:24

SQL 语句基础（增删改查）

文章目录一、SQL 基础概念1. SQL 简介2. 数据库系统的层次结构二、SQL 语句分类1. DDL（Data Definition Language 数据定义语言）1.1 CREATE1.1.1 创建数据库1.1.2 创建数据表1.1.3 创建用户 1.2 ALTER1.2.1 AlTER 添加字段名1.2.2 ALTER 修改字段名1.2…...

编程日记 2025/8/17 20:04:33

【蓝桥杯 CA 好串的数目】题解

题目链接考虑令 p r e [ i ] pre[i] pre[i] 表示 [ p r e [ i ] , i ] [pre[i], i] [pre[i],i] 是连续非递减子串，这可以类似双指针 O ( n ) O(n) O(n) 预处理： std::vector<int> pre(n); for (int r 1, l 0; r < n; r) {if (s[r] ! s[…...

编程日记 2025/9/11 10:21:28

Oracle for Linux安装和配置（11）——Linux命令

11.1. Linux命令 Linux是目前比较常用和流行的操作系统，现在很多生产环境就会用到它。随着其功能、性能、稳定性和可靠性等方面的日渐增强和完善，加之其成本上的优势，其市场占有率逐日攀升，也得到越来越多广大用户的关注和青睐。但作为一种操作系统，其安装、配置、管理和…...

编程日记 2025/9/9 9:48:44

Linux基础7

一、逻辑卷管理查看所有物理卷：pvs 查看当前系统卷组：vgs 查看所有逻辑卷：lvs 新创建系统卷组：vgcreate [参数] [volume name] url/sdb[1-2] eg：vgcreate vg_Test /dev/sdb{1,2} >…...

编程日记 2025/9/6 15:29:48

C#打开文件及目录脚本

如果每天开始工作前都要做一些准备工作，比如打开文件或文件夹，我们可以使用代码一键完成。 using System.Diagnostics; using System.IO;namespace OpenFile {internal class Program{static void Main(string[] args){Console.WriteLine("Hello, …...

编程日记 2025/9/7 22:59:09

Docker 镜像的常用命令介绍

拉取镜像 $ docker pull imageName[:tag][:tag] tag 不写时，拉取的是 latest 的镜像查看镜像查看所有本地镜像 docker images or docker images -a查看完整的镜像的数字签名 docker images --digests查看完整的镜像ID docker images --no-trunc只查看所有的…...

编程日记 2025/8/17 19:19:24

Python数组学习之旅：数据结构的奇妙冒险

Python数组学习之旅：数据结构的奇妙冒险第一天：初识数组的惊喜阳光透过窗帘缝隙洒进李明的房间，照亮了他桌上摊开的笔记本和笔记本电脑。作为一名刚刚转行的金融分析师，李明已经坚持学习Python编程一个月了。他的眼睛因为昨晚熬夜编程而微微发红，但脸上却挂着期待的微…...

编程日记 2025/9/5 18:12:32

Vue 3 和 Vue 2 的区别及优点

Vue.js 是一个流行的 JavaScript 框架，广泛用于构建用户界面和单页应用。自 Vue 3 发布以来，很多开发者开始探索 Vue 3 相较于 Vue 2 的新特性和优势。Vue 3 引入了许多改进，优化了性能、增强了功能、提升了开发体验。本文将详细介绍 Vue 2 和…...

编程日记 2025/9/8 13:07:58

特殊定制版，太给力了！

今天给大家分享一款超棒的免费录屏软件，真的是录屏的好帮手！ 这款软件功能可以录制 MP4、AVI、WMV 格式的标清、高清、原画视频，满足你各种需求。云豹录屏大师多功能录屏神器它的界面特别简洁，上手超快，用起来很顺…...

编程日记 2025/9/9 5:49:29

Vue事件修饰符课堂练习

Vue事件修饰符课堂练习题目‌：基于 Vue 2.0，使用事件修饰符 .stop、.prevent、.capture、.self 和 .once，为按钮绑定 click 事件，并展示每个修饰符的作用。要求‌： 创建一个 Vue 实例，并绑定到一个 HT…...

编程日记 2025/9/12 9:50:53

Y1——ST表

知识点 ST表只能询问，不能修改 ST表的预处理： 使用了DP的思想，设a是要求区间最值的数列，f(i,j)表示从第i个数起连续2^j个数中的最大值状态转移方程 f [ i , j ]max( f [ i , j-1 ], f [ i 2 ^ j-1,j - 1]) 建立ST表 vo…...

编程日记 2025/8/17 19:23:19

Python Cookbook-5.14 给字典类型增加排名功能

任务你需要用字典存储一些键和“分数”的映射关系。你经常需要以自然顺序(即以分数的升序)访问键和分数值，并能够根据那个顺序检查一个键的排名。对这个问题，用dict 似乎不太合适。解决方案我们可以使用 dict 的子类，根据需要增加或者重…...

编程日记 2025/9/12 9:52:17

第二十二： go与k8s、docker相关编写dockerfile

实战演示k8s部署go服务，实现滚动更新、重新创建、蓝绿部署、金丝雀发布-CSDN博客 go 编写k8s命令： 怎么在go语言中编写k8s命令 • Worktile社区 k8s中如何使用go 在K8s编程中如何使用Go-阿里云开发者社区 go build - o : -o：指定输出文件…...

编程日记 2025/9/12 8:16:18

Servlet、HTTP与Spring Boot Web全面解析与整合指南

目录第一部分：HTTP协议与Servlet基础 1. HTTP协议核心知识 2. Servlet核心机制第二部分：Spring Boot Web深度整合 1. Spring Boot Web架构 2. 创建Spring Boot Web应用 3. 控制器开发实践 4. 请求与响应处理第三部分：高级特性与最…...

编程日记 2025/9/7 14:47:21

事件过滤器

1.简介事件过滤器是指在程序分发到event事件之前进行的一次高级拦截。 2.使用步骤给控件安装事件过滤器重写eventfilter事件 3.具体实现 3.1安装事件过滤器代码： //给label1安装事件过滤器ui->label->installEventFilter(this); 3.2重写eventfilter…...

编程日记 2025/9/9 8:04:42

AI识别与雾炮联动：工地尘雾治理新途径

利用视觉分析的AI识别用于设备联动雾炮方案背景在建筑工地场景中，人工操作、机械作业以及环境因素常常导致局部出现大量尘雾。传统监管方式存在诸多弊端，如效率低、资源分散、监控功能单一、人力效率低等，难以完美适配现代工程需求。例如…...

编程日记 2025/9/12 6:01:32

Kubernetes nodeName Manual Scheduling practice (K8S节点名称绑定以及手工调度)

Manual Scheduling 在 Kubernetes 中，手动调度框架允许您将 Pod 分配到特定节点，而无需依赖默认调度器。这对于测试、调试或处理特定工作负载非常有用。您可以通过在 Pod 的规范中设置 nodeName 字段来实现手动调度。以下是一个示例： apiVe…...

编程日记 2025/9/9 13:04:57

Nacos注册中心

Nacos注册中心本地环境搭建准备挂载的文件夹在拉取 Nacos 镜像之前，在 E:\docker 文件夹下，创建一个 /nacos 文件夹，等会运行容器时，用于将 Nacos 容器中的配置文件、持久化文件挂载出来，防止容器重启时数据丢失…...

编程日记 2025/9/11 15:04:19

除了 `task_type=“SEQ_CLS“`（序列分类），还有CAUSAL_LM，QUESTION_ANS

task_type="SEQ_CLS"是什么意思：QUESTION_ANS 我是qwen，不同模型是不一样的 SEQ_CLS, SEQ_2_SEQ_LM, CAUSAL_LM, TOKEN_CLS, QUESTION_ANS, FEATURE_EXTRACTION. task_type="SEQ_CLS" 通常用于自然语言处理（NLP）任务中，SEQ_CLS 是 Sequence Classif…...

编程日记 2025/9/8 21:40:39

二战蓝桥杯所感

🌴 前言今天是2025年4月12日，第十六届蓝桥杯结束，作为二战的老手，心中还是颇有不甘的。一方面，今年的题目比去年简单很多，另一方面我感觉并没有把能拿的分都拿到手，这是我觉得最遗憾的地方。不…...

编程日记 2025/9/9 3:03:21

深度解析自动化工作流工具：n8n 与 Dify 的对比分析

深度解析自动化工作流工具：n8n 与 Dify 的对比分析随着企业数字化转型的加速，自动化工具在提高工作效率、降低人工成本方面扮演着越来越重要的角色。市面上有多种自动化工作流工具可供选择，其中 n8n 和 Dify 是两个备受关注的开源和商业产品…...

编程日记 2025/9/7 4:13:30

深度剖析Python中的生成器：高效迭代的秘密武器

深度剖析Python中的生成器：高效迭代的秘密武器在Python的编程世界里，生成器（Generator）是一个强大而又迷人的特性，它为开发者提供了一种高效处理大量数据的方式，尤其在涉及到迭代操作时，能显著…...

编程日记 2025/9/10 14:55:04

Mac 下载 PicGo 的踩坑指南

Mac 下载 PicGo 的踩坑指南一、安装问题下载地址：https://github.com/Molunerfinn/PicGo/releases 下载之后直接安装即可，此时打开会报错：Picgo.app 文件已损坏，您应该将它移到废纸篓。这是因为 macOS 为了保护用户不受恶意…...

编程日记 2025/9/12 6:56:53

网页布局汇总

1. 盒模型容器大小内容大小内边距(padding) 边框大小 <!DOCTYPE html> <html lang"en"> <head><meta charset"UTF-8"><meta name"viewport" content"widthdevice-width, initial-scale1.0">&l…...

编程日记 2025/9/10 14:07:42

基于 Maven 构建的 Thingsboard 3.8.1 项目结构

一、生命周期（Lifecycle） Maven 的生命周期定义了项目构建和部署的各个阶段，图中列出了标准的生命周期阶段： clean：清理项目，删除之前构建生成的临时文件和输出文件。validate：验证项目配置是否…...

编程日记 2025/9/8 12:58:27

MySQL 中为产品添加灵活的自定义属性（如 color/size）

方案 1：EAV 模型（最灵活但较复杂） 适合需要无限扩展自定义属性的场景 -- 产品表 CREATE TABLE products (id INT PRIMARY KEY AUTO_INCREMENT,name VARCHAR(100),price DECIMAL(10,2) );-- 属性名表 CREATE TABLE attributes (id INT PRIMA…...

编程日记 2025/9/11 12:42:47

C++语言程序设计——02 变量与数据类型

目录一、变量与数据类型（一）变量的数据类型（二）变量命名规则（三）定义变量（四）变量赋值（五）查看数据类型二、ASCII码三、进制表示与转换（一&…...

编程日记 2025/9/2 17:59:14

第三篇：Python数据结构深度解析与工程实践

第一章：列表与字典 1.1 列表的工程级应用 1.1.1 动态数组实现机制 Python列表底层采用动态数组结构，初始分配8个元素空间，当空间不足时按0,4,8,16,25,35...的公式扩容，每次扩容增加约12.5%的容量通过sys模块可验证扩容过程&a…...

编程日记 2025/9/11 19:53:00

dcsdsds

我将为您在页面顶部添加欢迎内容，同时保持整体风格的一致性。以下是修改后的代码，主要修改了模板部分和对应的样式： vue 复制 <template><div class"main-wrapper"><div class"…...

编程日记 2025/9/10 10:20:58

Vitis: 使用自定义IP时 Makefile错误导致编译报错

参考文章: 【小梅哥FPGA】 Vitis开发中自定义IP的Makefile路径问题解决方案 Vitis IDE自定义IP Makefile错误（arm-xilinx-eabi-gcc.exe: error: *.c: Invalid argument）解决方法 Vitis 使用自定义IP时: Makefile 文件里的语句是需要修改的，…...

编程日记 2025/9/6 20:15:45

应急响应练习靶机-web1

1）背景小李在值守的过程中，发现有CPU占用飙升，出于胆子小，就立刻将服务器关机，这是他的服务器系统，请你找出以下内容，并作为通关条件： 1.攻击者的shell密码 2.攻击者的IP地址 3.攻击…...

编程日记 2025/9/9 18:57:53

cdp－(Chrome DevTools Protocol) browserscan检测原理逆向分析

https://www.browserscan.net/zh/bot-detection 首先,打开devtools后访问网址,检测结果网页显示红色Robot,标签插入位置,确定断点位置可以hook该方法,也可以使用插件等方式找到这个位置,本篇不讨论. Robot标签是通过insertBefore插入的. 再往上追栈可以发现一个32长度数组,里面…...

编程日记 2025/9/10 6:47:02

MCU刷写——Hex文件格式详解及Python代码

工作之余来写写关于MCU的Bootloader刷写的相关知识，以免忘记。今天就来聊聊Hex这种文件的格式，我是分享人M哥，目前从事车载控制器的软件开发及测试工作。学习过程中如有任何疑问，可底下评论！如果觉得文章内容在工作学习中有帮助到你，麻烦点赞收藏评论+关注走一波！感谢…...

编程日记 2025/9/8 1:28:32

SpringBoot(一)

快速入门 1.概念 SpringBoot 简单、快速地创建一个独立的、生产级别的 Spring 应用（说明SpringBoot底层是Spring） 大多数 SpringBoot 应用只需要编写少量配置即可快速整合 Spring 平台以及第三方技术特性： 快速创建独立 Spring 应用 SSM&…...

编程日记 2025/9/11 12:35:15

学习Mysql对库和表的操作以及对数据的操作

对库操作 SHOW DATABASES;可以查看数据库服务器中有哪些数据库(注意databases最后的s不要忘记) SELECT DATABASE();可以查看到目前是在哪个数据库下。 CREATE DATABASE 库名;可以创建一个数据库 DROP DATABASE 库名;可以删除一个数据库 USE 库名;切换到当前数据库对表操…...

编程日记 2025/9/11 15:10:11

Java中parallelStream并行流使用指南

1. 基本用法

2. 并行流 vs 顺序流

3. 注意事项

(1) 线程安全问题

(2) 避免有状态操作

(3) 性能考量

(4) 默认线程池

4. 适用场景

5. 示例

(1) 并行求和

(2) 并行过滤

(3) 自定义线程池（Java 8+）

6. 总结

相关文章：