问题标签 [parallelstream]

我有以下代码使用并行流打印列表的元素：

输出：

为什么并行流在6大多数时候开始？
为什么不开始0？为什么不是中间？

该方法 (transformAll) 为一个人和他们的朋友转换所有的 img。我们可以对这两种方法做一个小的修改，以便可以并行转换 imgs 吗？例如使用 ParallelStream()。transformImige() 方法只是一个简单的方法，不执行 I/O。另外，我们可以在 transformAll() 方法中使用流吗？

问：Person 类是监控模式的有效实现吗？

我需要使用并行流运行集合，并且它始终按顺序运行，在下面的示例中，列表始终按顺序IntStream运行，而并行运行。Stream可以请一些人帮助我了解运行并行运行IntStream和并行Stream运行之间的区别List<String>。

此外，您能否帮助代码片段如何List<String>并行运行类似于如何IntStream并行运行？

上述代码的输出如下。

我正在处理 2 个 csv 文件并检查常见条目并将它们保存到一个新的 csv 文件中。但是比较需要很多时间。我的方法是首先将文件中的所有数据读入 ArrayList，然后在主列表上使用 parallelStream，我在另一个列表上进行比较，并使用字符串生成器附加常见条目，然后将其保存到新的 csv 文件中。下面是我的代码。

目前处理需要数小时。我怎样才能让它快点？

有没有办法使用 对列表进行排序parallelStream()？我看到有forEach和forEachOrdered。但我正在检查是否有如下排序方法，

我有如下方法：

我想将 for 循环转换为并行流，有人可以告诉我上述方法中的代码更改应该是什么吗？PS - method1 和 method2 正在返回 list2 的修改版本。

我目前正在使用 LocaleContextHolder.getLocale() 来获取语言环境。

但问题是，有时它会返回没有国家代码的语言代码。

例如：有时en_US有时仅en

可能的原因是什么？

仅供参考：运行环境是：Java11，spring5.3.9。

如何确保 getLocale() 方法应该返回 lang-code_country-code (en_US) ？

任何帮助将不胜感激 ！

简化问题陈述

在并行流中使用 LocaleContextHolder.getLocale() 时，LocaleContextHolder.getLocale() 为子线程提供不同的语言环境。例如，对于主线程en_us和其他线程en。

输出线程

nio-8080：en_US，onPool-worker：en，......，onPool-worker：en

我正在为国际象棋引擎使用 Java 并行流。该流用于评估给定移动列表中的每个国际象棋移动。每个 Move 都映射到一个表示 Move 值的 Integer，然后我将所有 Integer 收集到一个 List 中并返回 List 中最大的 Integer。

这似乎很容易，但我想将我的流设计为如果通过流的整数匹配某些条件也立即终止。

例如，如果我有 100 个要转换为流的 Move 的列表，如果这些 Move 中的任何一个映射到小于 4 的 Integer，我希望我的流立即终止，否则我想将这些 Integer 收集到一个列表（这只是一个帮助澄清的例子）。

我不知道该怎么做（我考虑过短路操作，但我不知道如何在流没有短路的情况下将短路操作与收集器结合使用）。我也很乐意澄清任何事情。谢谢！

I am trying to use multi-threading to sort arrays that are stored in a map. There are a large amount of records, ~3.1 million, and thus while I am attempting to sort these records in a single threaded for loop it takes many hours to complete. I'm hoping to get this time down as much as possible, ideally within a few minutes (please don't laugh!).

Stacktrace:

Class Object:

The Code:

And I'm trying to execute this in the code like this:

NOTE: this is not what I want to do, but I initially wrote the code like this and it worked. That is to say, my comparator works if I do it this way.

however, it takes for.ev.er to complete, which sadly is not acceptable for our business case. What can this noob do to make this parallelStream() or some way of threading this work?? If you need more info, please let me know! Thanks so much!!

Edit: I want to also give you guys a sample of the data below. So this is a Map<String,List<MyObject>>.

so, If I wanted to sort key3 list of objects, they would return like this:

and, I want to do this sort function on every record.

介绍

我目前正在开发一个我使用的程序Java.util.Collection.parallelStream()，并想知道是否有可能使其更加多线程。

几个小地图

我想知道使用多个map是否可以Java.util.Collection.parallelStream()更好地分配任务：

单张大图

例如，比以下更好的分布：

问题

有没有更适合的方案之一Java.util.Collection.parallelStream()，还是两者没有太大区别？