fork-join

1热度

5回答

我已经开始使用fj JAVA框架。据我了解，它只是分裂算法计算这样的大任务，并将其分为小线程。问题是如果它值得在单处理器机器上使用这个框架。谢谢

0热度

1回答

我有这样的代码，串接/组合图像的集合。我想将这个顺序代码重组为一个并行/分布式应用程序，因为我的图像集合非常大（大数据:-)）。我正在考虑Map/Reduce，但不确定在Map/Reduce下这是否可行。 #Sequential Code Result.Image <- NULL foreach(Image in Image.Collection) { Result.Image <-

1热度

4回答

使用Java中的执行程序写文件

我有一个List<Map<String,String>> ie;地图列表。每个地图都有File Name作为Key和File Content作为Value。我在上面的列表中有超过25个拉赫地图。我的要求是遍历这个列表，并创建文件到输出文件夹读取每个Map键和值。所以最后我会有25万个文件。它需要4个多小时。然后我停止该程序。如果我运行整个25lakh记录的程序，我不知道确切的时间。我需要使用多

2热度

1回答

ForkJoinPool中有多少个线程工作者？

我怎么知道ForkJoinPool有多少线程？我们假设ThreadForkJoinPool实现。我有双核心。第二个快速问题：同步（锁）是否也可以并行？在此先感谢。

0热度

1回答

的Java叉加入问题

我学习Java中的fork-join技术，写了下面的程序。我正在运行for循环（5次），我想在单独的线程中运行for循环的内容。这是正确的。问题是，当所有线程完成时，我想要一个大小为5的向量，它必须包含在索引0处执行线程1的结果，在索引1处执行线程2的结果........ ....在索引4处执行线程5的结果。我干净地直观地显示了我想实现的内容，但不知道它的语法。目前，我会在我的向量1号。 imp

-1热度

1回答

fork（）最终调用计算吗？

我的理解是它创建另一个线程并在另一个线程中运行compute（）。然后连接一旦递归获取它就获取结果。我想知道fork()是否调用compute()或不。提前致谢。

3热度

1回答

它们与asyncMode的含义是什么？

直接从该javadoc：这个类提供适应可运行和可调用的方法，与其他类型的任务混合的ForkJoinTasks执行时可能是有用的。当所有任务都是这种形式时，请考虑使用在asyncMode中构建的池。这实际上是什么意思asyncMode在这种情况下？我怎样才能在asyncMode中构建一个池？

6热度

1回答

ForkJoinPool中执行，提交和调用（）之间的区别

我有以下类，它运行并编译（可以试试）。唯一令我感到困惑的是，在主结束时，它可以很好地与fj.invoke（task）协同工作，但不会与fj.execute（task）和fj.submit（task）一起工作。后者不会得到任何输出。从API它应该与其他方法一起工作，即使它们要么返回值，要么仍然执行任务。我在这里错过了什么？ import java.util.concurrent.Recursiv

4热度

1回答

Java 7的fork/join框架并未使用所有可用的CPU电源

我正在使用Java's fork-join framework来处理CPU密集型计算。我已经调整了“顺序阈值”（用于确定是创建子任务还是做这项工作），但令人失望的是，从单线程到4 + 4核心只有将整体性能提高了一倍。该池确实报告了8个CPU，当我手动设置2,3,4时，..我看到性能逐渐增加，但仍然达到总体单线程吞吐量的两倍左右。此外，Linux系统活动监视器为该Java进程徘徊约50％。也非常可

5热度

1回答

阿卡 - 负载测试期间，forkjoinpool.scan在cpu时间

我们正在做的负载测试了一些良好的进展和缩放的阿卡应用程序，但我们看到scala.concurrent.forkjoin.ForkJoinPool.scan 20％（）到来作为visualvm中自我时间的20％左右的第二高热点。自我时间（CPU）列仅显示其中的一小部分（小于自我时间列值的1％）。我怀疑这意味着阻止或上下文切换都可能存在问题，但我也不太清楚 - 任何一个可以深入了解？如果是上下文切