我有一个类似下面的Java代码：ForkJoinPool pool = new ForkJoinPoolcondition)pool.shutdown();
现在，这段代码运行得足够快，使用了我机器中的所有32个线程，每个线程
浏览 19提问于2017-08-01得票数 3
1回答
为什么阿克卡把这些线都停下来了？
、、、、
我正在使用Akka并行地执行一组非常短的任务。我使用system.actorOf创建了一个父Actor，使用context().actorOf创建了25个其他Actor。然后，我在父Actor中调用context().stop(getSelf())，它应该会停止所有的子级。我正在观察VisualVM中的线程状态，以了解Akka在后台是如何工作的，并且我注意到，当我在父Actor上调用stop()时，Akka生成的线程在不同的时间开始缓
浏览 2提问于2016-02-29得票数 3
回答已采纳
我正在使用parallelStream并行上传一些文件，有些是大文件，有些是小文件。我注意到并不是所有的工人都被使用了。似乎所有的工作(列表中的项目)都分布在16个线程中，委托给一个线程的事情只会等待线程空闲<
浏览 26提问于2018-09-05得票数 2
回答已采纳
我理解java parallelStream(或ForkJoinPool)是为了最大限度地利用CPU而设计的。由于java流功能接口(如map、reduce、filter)和ForkJoinPool的结合非常好，所以我使用了java并行流和ForkJoinPool。问题是ForkJoin没有限制活动线程的数量。如果某些线程在内存较大时被阻塞，ForkJoinPool会</e
浏览 2提问于2020-12-23得票数 2
回答已采纳
2回答
我正在编写一个程序，并决定使用新的StreamsAPIforJava8。然而，当我引入.parallel()时，我的程序停止了工作。以下是相关代码：import java.util.Objects; } }当正确工作时，输出将包含许多PROCESSING <x>行，但
浏览 0提问于2015-04-15得票数 0
回答已采纳
(我使用的是ConcurrentHashMap而不是ConcurrentSkipListSet，因为该类没有实现可比性。)我在计算机上有很多免费的CPU，在流中运行的类之间没有区别(除了随机数生成)。令人怀疑的是，偶数是第一个(一致的)。
下面是nRuns=10的代码和输出，我希望所有10个线程都能同时启动和运行(就像我在ConcurrentHashMap的其他用法中通常所做的那样)。这是否是由Sv
浏览 6提问于2020-06-28得票数 0
回答已采纳
我对ExecutorService和ForkJoinPool的内部调度机制有点困惑。许多任务都在排队。一旦线程可用，它将处理第一个可用任务，依此类推。
同时，由于ForkJoinPool使用了的偷功算法，所以它被表示为不同.如果我正确理解，这意味着一个线程可以从另一个线程中窃取一些任务。然而，我并不真正理解在ExecutorService和<em
浏览 2提问于2018-10-09得票数 10
回答已采纳
1回答
如何正确使用Java执行器？
、、、、
我在多线程应用程序中使用了Java执行器，但我似乎不知道什么时候最好使用以下每一种方式：for (Future<String> future : futures) String f=future.get();}我想知
浏览 4提问于2015-11-08得票数 12
回答已采纳
我有一个可完成的未来，它只运行另一个可完成的未来(总是花费大约2秒，超时50 ms)，并等待它以超时1秒完成。问题是，内部未来的超时从来不起作用，但是get工作了大约2秒，尽管它有50 ms的超时时间，从而导致外部CompletableFuture超时。2 took 62 ms2 started2 timed outinner completedsuccessfully
i
浏览 14提问于2022-08-23得票数 4
我有一个函数，它使用parallelStream在forEach中迭代列表，然后以param的形式调用一个API。然后，我将结果存储在一个hashMap中。通过一些基础研究，我发现并行流使用默认的ForkJoinPool.commonPool，在默认情况下，它与处理器一样少了一个线程。
Laptop1和laptop2有不同的处理器。我是否可以使用的建议来安全地增加laptop2中的并行流的<
浏览 4提问于2021-01-06得票数 1
使用lambda，但是没有使用自定义执行器的方法的风格，甚至也没有它的"...Async“风格。
特别拉姆达是在哪个执行器上运行的？会不会是运行抛出异常的原始CompletableFuture的同一个执行者呢？或者(如果是这样的话，我会很惊讶)是commonPool吗？
浏览 1提问于2016-07-07得票数 10
回答已采纳
1回答
我使用了一个与一起运行的Java webapp应用程序。Tomcat线程池的最大线程为800，minSpareThreads为25。当它运行时，它通常在给定的时间内处于大约400个运行线程的位置。假设我有一个计算上昂贵的、非阻塞的任务，我必须在我的Tomcat应用程序中完成，在这个应用程序中，ForkJoinPool.commonPool可以更有
浏览 0提问于2021-08-31得票数 1
回答已采纳
在并行序列上映射时，Scala似乎为每个计划的计算元素分配了一个固定的CPU核心，然后防止这种初始分配发生变化。Core 1: a, b, c, d, e, f问题是，如果(a .. f)非常快，而(g .. l)每个都需要1小时，那么我们最终将导致Core1空闲6个小时，而Core2正试图完成它的工作。在开始的时候，所有的核心都是100%，当你进步的时候，你可以清楚地看到每个进程在它开始之前都有自己的
浏览 3提问于2017-10-24得票数 0
回答已采纳
我想为工作窃取池所使用的ForkJoinPool线程设置名称，由或到目前为止，我还没有找到在这个ExecutorService使用的线程上设置自定义名称的方法，有办法吗？newWorkStealingPool()基本上提供了一个ForkJoinPool，但是ForkJoinPool
浏览 4提问于2015-12-16得票数 16
回答已采纳
poolRunner方法创建了一个ForkJoinPool并向它提交了一些任务。(ForkJoinWorkerThread.java:187)
将线程存储在JDK 8中，但是WAIT在JDK 11中。在Java 11
浏览 0提问于2019-01-08得票数 4
在使用Java并行流时，当一些并行操作在静态初始化程序块中完成时，我遇到了死锁。ForkJoinPool管理之间的交互有关)：public class Example3 { // hangsSystem.out.println(s)) }
public static final void main(String[] arg
浏览 0提问于2018-10-30得票数 3
我有一个带有Java 11的spring引导项目，项目依赖于redis，所以我在pom.xml中包含了spring starter redis依赖项。spring有一个名为JedisClientUtils的类，它在类级别有一个默认的访问修饰符。在调试问题时，我发现同一个项目在使用Java8时成功运行。spring-boot-maven-plugin</artifactId> <&
浏览 2提问于2019-07-10得票数 2
2回答
从这篇中，我只能部分地了解到，至少在某种程度上，java嵌套并行流存在问题。然而，我无法推导出以下问题的答案：Java</e
浏览 0提问于2017-08-08得票数 1
注意:我已经在另一个如此后的 -中讨论了这个问题，但是这篇文章的标题表明这个问题与信号量的使用有关--这在一定程度上分散了讨论的注意力。因此，每个线程总共消耗11秒(最坏的情况)。我们有一个布尔值，它允许将内循环从并行()切换到序列()。这是人们从框架中所期望的吗？(我现在更加谨慎地声称这是一个bug，但我个人认为这是由于ForkJoinTask实现中的一个错误造成的。numberOfTasksIn
浏览 22提问于2014-05-06得票数 21
我有一个java程序，其中一部分是计算密集型的，如下所示 COMPUTE INTENSIVE SECTION我想把它分成多个线程，让它在运行时更快。计算密集型部分不是按顺序进行的。这意味着先运行i=1或i=5 fist是相同的……
有没有人能给我一个很棒的指导。该怎么做呢？真的很感谢！感恩节快乐!
浏览 0提问于2010-11-25得票数 5
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
