我正在为我的Java并发类(class)编写教程。目标是使用线程池并行计算素数。该设计基于埃拉托色尼筛法。它有一个包含n个boolean值的数组，其中n是您要检查的最大整数，数组中的每个元素代表一个整数。真为素数，假为非素数，数组初始全为真。线程池使用固定数量的线程(我们应该试验池中的线程数并观察性能)。一个线程被赋予一个整数倍来处理。然后线程找到数组中第一个不是线程整数倍数的真元素。然后该线程在线程池中创建一个新线程，该线程被赋予找到的编号。新线程形成后，现有线程继续将数组中所有它的整数倍数设置为false。主程序线程以整数“2”启动第一个线程，然后等待所有派生的线程完成。然后它会吐

是否有这样的Java类:可以通过id添加可执行任务，保证所有具有相同id的任务永远不会同时运行可以将线程数限制在固定数量简单的Map解决方案很容易解决(1)，但很难管理(2)。同样，我所知道的所有线程池类都将从单个队列中提取，这意味着(1)不能保证。欢迎使用涉及外部库的解决方案。 最佳答案 对于每个id，你需要一个SerialExecutor，在java.util.concurrent.Executor的文档中有描述。.所有串行执行器将工作委托(delegate)给ThreadPoolExecutor具有给定的corePoolSiz

我想知道线程如何以及何时在可运行和运行状态之间来回移动。幕后实际发生了什么。我想这在ThreadPool的情况下是需要的，但我无法完全理解。请帮助我理解这一点。 最佳答案 ifthreadisinrunningstatethatmeansitsexecutingrun()methodandwhenitsinrunnablemethoditsexecutingstart()method....soIguessmovingfromrunningtorunnablemeansitsgoingbackfromrun()tostart()在大

我想创建一个固定大小的线程池，不允许任何任务进入其队列。换句话说，如果线程池当前正在使用中，传入的任务应该被彻底拒绝。基于documentation，在我看来，一种方法是创建一个拒绝接受任务的虚拟Queue对象。在Java中实现此目的的惯用方法是什么？ 最佳答案 您可以使用SynchronousQueue在您的ThreadPoolExector中，这是一个不包含任何对象的队列。缓存线程池使用它是因为它按需创建新线程。如果无法排队，但我建议使用RejectedExecutionHandler在当前线程中运行任务。这样它将始终“立即”运

JavaSE6文档中的ThreadPoolExecutor类具有以下method:publicintgetActiveCount()Returnstheapproximatenumberofthreadsthatareactivelyexecutingtasks.这里的approximate和activelyexecution是什么意思？是否有任何保证，如果在调用getActiveCount()之前、期间和之后N个线程已从池中分配给任务执行，并且这N个线程都不可用于进一步的任务分配，getActiveCount()返回的整数正好是N？如果getActiveCount()不提供这种保证，

我有一组记录要处理，处理可以并行进行，所以我创建了一个ExecutorService(通过Executors#newCachedThreadPool())。单个记录的处理本身由可并行化的步骤组成，因此我想使用另一个ExecutorService。有没有一种简单的方法可以让这个新的使用相同的底层线程池？它甚至是可取的吗？谢谢。 最佳答案 回答您的问题:不，两个ExecutorService对象不能共享一个线程池。但是，您可以在对象之间共享一个ExecutorService，或者根据需要创建多个Executor，但不太推荐这样做。最佳解

如果这个问题听起来很愚蠢，请原谅我——我才刚刚开始使用Executor。我有一个以这种方式使用线程的现有Java应用程序——基本上使用独立线程——privateThreadspawnThread(){Threadt=newThread(){StringtaskSnap=task.toString();publicvoidrun(){try{println(task.run(null));}catch(InterruptedExceptione){println("ITC-"+taskSnap+"interrupted");}}};returnt;}从上面可以看出，该函数返回一个新线程。

我有一个关于java和并发的问题。假设我有一个名为“a”的ThreadLocal变量。我使用CachedThreadPool来获取新线程。当线程被重用时，ThreadLocal变量'a'会发生什么变化？它保持相同的值(因为它是同一个线程)还是它开始为空(就像线程是新的一样)？ 最佳答案 默认情况下，ThreadLocals与线程一起重用。如果您需要重新初始化它们，您可以通过覆盖下面提到的方法来实现:fromjavadocforjava.util.concurrent.ThreadPoolExecutorHookmethodsThis

来自AsynchronousFileChannel应用程序接口(interface):WhenanAsynchronousFileChanneliscreatedwithoutspecifyingathreadpoolthenthechannelisassociatedwithasystem-dependentdefaultthreadpoolthatmaybesharedwithotherchannels.我没有在其他地方看到过这个术语，也没有通过网络搜索找到任何具体的解释。系统相关的默认线程池到底是什么？它有什么特点？它们在系统之间有何不同？ 最佳答案

有大量的任务。每个任务都属于一个组。要求是每组任务应该像在单线程中执行一样串行执行，并且吞吐量应该在多核(或多cpu)环境中最大化。注:还有海量组，与任务数量成正比。天真的解决方案是使用ThreadPoolExecutor和同步(或锁定)。但是，线程会相互阻塞，吞吐量不会最大化。有更好的主意吗？或者有没有第三方库可以满足要求？ 最佳答案 一种简单的方法是将所有组任务“串联”为一个super任务，从而使子任务连续运行。但这可能会导致其他组延迟，除非其他组完全完成并在线程池中腾出一些空间，否则这些组不会启动。作为替代方案，请考虑将一组任