问题标签 [parallelstream]

我正在尝试将传统的 for 循环转换为 Java Stream，但出现了一些问题。基本上，我的方法执行花费了太多时间。当我描述减少方法执行时间时。将传统的for循环转换为JavaStream时List size为0，否则使用传统for循环的list size不是0，耗时太长。请，任何人，解决这个问题。

1.

上述代码段转换成Java流是否正确，请编辑我。

2.

上述代码段转换成Java流是否正确，请编辑我。

第二个循环。ProductProjection 大小列表：1238 和 CourseBatch 大小列表：1124

我正在使用 parallelStream() 解析 CSV 文件，并注意到一些奇怪的行为。有问题的代码在这里：

我调用上述方法的控制器：

例如，有时我在前端得到的错误是“在第 3 行检测到太多列”，这是我所期望的。有时我得到的错误是“java.lang.IllegalArgumentException：在第 3 行检测到太多列”，我不确定为什么它也会打印出异常名称？我在这里缺少什么吗？

我正在使用 Vertx 和 Log4j2。

这是代码Remote.java

这是我的代码StartVerticle.java

当我运行上面的代码时，我的输出是

您能帮我获得以下输出吗？

我还打印了线程名称以供参考。在不使用 Vertx 的情况下，我可以ThreadContext在设置isThreadContextMapInheritable为true.

这里大致是我要更改的代码：

我想更改 evaluator.evaluate() 方法以返回 Pair<List, List> 。就像是：

这样，如果 evaluatorA 返回 Pair<[1,2], [a,b]> 并且 evaluatorB 返回 Pair<[3], [c,d]> 那么最终结果是 Pair<[1,2,3]， [a,b,c,d]>。

谢谢你的帮助。

我正在使用并行流来处理大型数据集。但它给出了不一致的结果。使用的数据库是 Postgres。我有定义了级别的分层数据。

例如，我在一个层次结构中有 5 个级别的数据。我首先处理最低级别（这里是 5 个）节点，持久保存到数据库。然后，当我在处理上一层（此处为 4）时，我必须获取已经保存在 5 级中的数据并对其进行处理并将 4 级数据保存到 db。

我正在为每个级别处理使用并行流。一旦第 5 级的过程完成，并且当我们尝试获取处理第 4 级节点的数据时，保存的数据不会反映。

当我在下面的代码中删除“parallelStream()”时，一切正常。但这需要太多时间

假设我们有以下设置：

如果我不使用原子变量，这段代码会执行得更快吗？使用原子变量是一种好习惯，还是尽可能避免使用它们？

其他链接： 具有原子变量的并行流竞争条件， 并行处理

在我的 java web 应用程序中是一个基于文件的集成。他们过去常常在我们的生产服务器 opt/app/proceed/ 文件夹中发送一堆 xml 文件（例如：10000）。但是根据当前配置，我们的应用程序能够在顺序处理中处理 200 个文件。因此，延迟处理文件。我正在尝试以并行方式增加文件处理的数量。请找到代码块供您参考。

如何着手改变文件处理方式。等待需要的支持/指导。

有人可以告诉我为什么会发生这种情况以及这是预期的行为还是错误

回答：10

但是如果我们使用stream而不是parallelStream我得到正确和预期 answer 7

只是尝试一个简单的示例来了解使用 foreachordered 进行流式处理时的异常处理。请写下当当前元素抛出异常 (1) 时我们如何继续对 list(20) 的下一个元素执行操作的建议。

假设我们有任务 1-8，我们有 2 个线程。任务 1-4 分配给线程 1，任务 5-8 分配给线程 2。可以分配执行顺序，例如，在开始任务 2 之前完成任务 1，任务 2 将根据任务的输出执行1 对于线程中的任务？