Loading [MathJax]/jax/output/CommonHTML/config.js

开发者社区

文档建议反馈控制台

文章/答案/技术大牛

发布

社区首页 >专栏 >设置并行流最大线程数

设置并行流最大线程数

作者头像

阿超

发布于 2022-08-21 03:15:55

发布于 2022-08-21 03:15:55

1.3K00

代码可运行

举报

文章被收录于专栏：快乐阿超快乐阿超

运行总次数：0

代码可运行

我们可以使用如下方式获取并行流线程数

并行流线程数获取

如果我们需要更改，则可以设置系统属性：

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

例如此处设置为8

则再次获取

可以看到是8个子线程+1个主线程，也就是9个线程

还可以使用ForkJoinPool.getCommonPoolParallelism()直接获取ForkJoinPool中允许设置的最大线程数

本文参与腾讯云自媒体同步曝光计划，分享自作者个人站点/博客。

原始发表：2022-01-20，如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自作者个人站点/博客前往查看

如有侵权，请联系 cloudcommunity@tencent.com 删除。

本文参与腾讯云自媒体同步曝光计划，欢迎热爱写作的你一起参与！

评论

登录后参与评论

暂无评论

编辑精选文章

换一批

万字详解高可用架构设计

Go 开发者必备：Protocol Buffers 入门指南

10分钟带你彻底搞懂分布式链路跟踪

多租户的 4 种常用方案

亿级月活的社交 APP，陌陌如何做到 3 分钟定位故障？

60页PPT全解：DeepSeek系列论文技术要点整理

IO密集型任务使用Java的parallelStream并行流，提高性能及隔离故障，如何自定义线程池

线程池性能 java io 系统

在Java中，parallelStream 是 Java 8 引入的 Stream API 的一部分，它允许并行处理集合中的元素。默认情况下，parallelStream 共享使用默认的 ForkJoinPool 作为其线程池，可能对你的业务影响性能，而且起不到隔离的作用。所以我们需要自定义其使用的线程池。

崔认知

2024/09/13

1.1K0

IO密集型任务使用Java的parallelStream并行流，提高性能及隔离故障，如何自定义线程池

异步任务编排神器CompletableFuture

并发编程异步编程腾讯技术创作特训营S8

但是当异步任务繁多并且复杂，任务间可能存在依赖关系时，Future接口变得不太好用

菜菜的后端私房菜

2024/08/15

4530

parallelStream的坑，不踩不知道，一踩吓一跳

很多同学喜欢使用lambda表达式，它允许你定义短小精悍的函数，体现你高超的编码水平。当然，这个功能在某些以代码行数来衡量工作量的公司来说，就比较吃亏一些。

xjjdog

2020/09/23

1.1K0

Java并行流指北

java 并发并发编程多线程 java-stream

参考 concurrency - Custom thread pool in Java 8 parallel stream - Stack Overflow

javalover123

2023/07/06

5340

Java 8 - 并行流计算入门

java linux unix

我们已经看到了新的 Stream 接口可以以声明性方式处理数据集，无需显式实现优化来为数据集的处理加速。到目前为止，最重要的好处是可以对这些集合执行操作流水线，能够自动利用计算机上的多个内核。

小小工匠

2021/08/17

1.3K0

【JDK8 新特性 7】并行的Stream流&parallelStream背后的技术

unix 编程算法安全

上一篇文章：(1条消息) 【JDK8 新特性 6】收集Stream流中的结果_一切总会归于平淡的博客-CSDN博客

叫我阿杰好了

2022/11/07

1.2K0

【JDK8 新特性 7】并行的Stream流&parallelStream背后的技术

04-CompletableFuture异步线程性能

小白和他的朋友门,连续输了10几把游戏, 决定去餐厅吃饭了,3个人,直接点了10盘菜,决定化悲愤为食量

彼岸舞

2022/05/10

3770

【小家java】Java线程池之---ForkJoinPool线程池的使用以及原理

java unix 编程算法

Java 7 引入了一种新的并发框架—— Fork/Join Framework。同时引入了一种新的线程池：ForkJoinPool（ForkJoinPool.coomonPool）

YourBatman

2019/09/03

2.2K0

【小家java】Java线程池之---ForkJoinPool线程池的使用以及原理

Java并行流Parallel Stream与Fork-Join线程池的关系，莫要乱用、滥用并行流

编程算法 unix

在说stream之前，给大家分享一个数组匹配性能优化技巧，其实平时注意一些编码的优化，对整个系统的性能优化是有很大帮助的，积少成多。往往一个项目都是毁在一行行粗心代码上的，比如这里多占点内存，那里多占点内存，慢慢内存就不够用了，结果就想着升级机器配置。

Bug开发工程师

2019/11/27

11.8K1

啥？用了并行流还更慢了

Java 8给大家带来了一个非常便捷的多线程工具：并行流，一改往日Java多线程繁琐的编程规范，只需要一行代码，就可以让一个多线程跑起来，似乎让很多人忘记了被多线程支配的恐惧，这篇文章给大家分享一个真实的生产故障，由于在消费消息的处理器中使用了Java 8的并行流，导致集群消费消息的能力急速下降，造成线上消息堆积，引发故障。可能有朋友会好奇，到底是什么场景让并行流起了反作用？

苦味代码

2021/03/11

6250

聊聊如何自定义parallelStream的线程池

factory private 配置系统线程池

org/springframework/scheduling/concurrent/ForkJoinPoolFactoryBean.java

code4it

2023/08/31

6820

聊聊如何自定义parallelStream的线程池

聊聊如何自定义parallelStream的线程池

org/springframework/scheduling/concurrent/ForkJoinPoolFactoryBean.java

code4it

2023/07/08

1.3K0

压测引发的思考——高并发用同步还是异步好？

java unix 缓存压力测试 https

最近616大促，公司的服务需要进行压力测试，使用了公司自己的压测平台。对生产机器进行了摘流量压测。由于服务都是查询的接口，也算是很好压测的。这篇文章大概描述压测过程过程，主要是压测出的问题的解决以及对ForkJoinPool学习和了解。（标题党？？？？？？？）

袁新栋-jeff.yuan

2021/12/07

9490

压测引发的思考——高并发用同步还是异步好？

java线程池,工作窃取算法

编程算法 jvm java

前言在上一篇《java线程池,阿里为什么不允许使用Executors?》中我们谈及了线程池，同时又发现一个现象，当最大线程数还没有满的时候耗时的任务全部堆积给了单个线程, 代码如下: ThreadP

落跑架构师M

2019/12/30

8840

java线程池,工作窃取算法

编程算法 jvm java

前言在上一篇《java线程池,阿里为什么不允许使用Executors?》中我们谈及了线程池，同时又发现一个现象，当最大线程数还没有满的时候耗时的任务全部堆积给了单个线程, 代码如下: ThreadP

落跑架构师M

2020/02/11

9600

CompletableFuture源码分析以及例子实证

默认情况下 CompletableFuture 会使用公共的 ForkJoinPool 线程池，这个线程池默认创建的线程数是 CPU 的核数（也可以通过 JVM option:-Djava.util.concurrent.ForkJoinPool.common.parallelism 来设置 ForkJoinPool 线程池的线程数）。

伍六七AI编程

2021/01/13

1.2K0

RecursiveTask和RecursiveAction的使用以及java 8 并行流和顺序流

转载自 https://blog.csdn.net/weixin_41404773/article/details/80733324

allsmallpig

2021/02/25

1.7K0

JUC并行计算框架 Fork/Join 原理图文详解&代码示例

unix 编程算法

关键词：divide and conquer algorithm，work-stealing，WorkQueue

一个会写诗的程序员

2020/05/08

3.4K0

深入浅出vue_深入浅出pandas

java 编程算法 http https javascript

Stream 不是集合元素，它不是数据结构并不保存数据，它是有关算法和计算的，它更像一个高级版本的 Iterator。原始版本的 Iterator，用户只能显式地一个一个遍历元素并对其执行某些操作；高级版本的 Stream，用户只要给出需要对其包含的元素执行什么操作，比如 “过滤掉长度大于 10 的字符串”、“获取每个字符串的首字母”等，Stream 会隐式地在内部进行遍历，做出相应的数据转换。

全栈程序员站长

2022/11/04

5170

Java 中的线程池

Java 在使用线程执行程序时，需要调用操作系统内核的 API，创建一个内核线程，操作系统要为线程分配一系列的资源；当该 Java 线程被终止时，这个内核线程也会被回收。因此 Java 线程的创建与销毁的成本很高，从而增加系统的性能开销。

真正的飞鱼

2022/08/19

9810

相关推荐

IO密集型任务使用Java的parallelStream并行流，提高性能及隔离故障，如何自定义线程池

更多 >

LV.1

gitee封面人物

作者相关精选

并行流线程数获取

加入讨论

的问答专区 >

大数据开发工程师擅长4个领域

相关课程

一站式学习中心 >

腾讯云WeData大数据开发与治理训练营

数据开发治理平台 WeData

AI驱动的TDSQL-Cserverless实战营

云原生数据库 TDSQL-C

腾讯云向量数据库快速上手训练营

向量数据库

本文部分代码块支持一键运行，欢迎体验

本文部分代码块支持一键运行，欢迎体验