线程池执行器

Question

我正在使用线程池执行器更改遗留设计。详情如下：-

遗留：-对于遗留设计，在应用程序启动时创建600个线程。和放置在各种池中，然后在需要时提取这些池，并将任务分配给相应的线程。

新：-在新设计中，我将线程池替换为执行器服务

 ThreadPoolExecutor thpool = new ThreadPoolExecutor(coreSize,poolsize,...);

我观察到的是，对于Executor，在启动时不会创建线程。它们是在从客户端激发请求时创建的。因此，与前一个线程相比，在内存中创建的线程要少得多。

但我的问题是，这样做是否正确，因为线程创建也是一种开销，这是在触发调用时发生的。

请告诉我们哪个线程更重，在客户端调用时创建进程线程，还是按照传统方法在内存中创建空闲线程。

还建议使用哪个执行器池，以便在性能方面获得最佳结果。

Answer 1

600听起来像很多。您可能希望将其降低到可用处理器的数量。或者，如果线程最终等待了很长时间，那么如果您的线程不是100%受CPU限制的，那么所产生的平均负载的因素就是TPE的可运行性。假设您有nCPUs=Runtime。getRuntime（）。availableProcessors（）和加载因子（loadFactor）作为线程上的平均负载（在测试中观察到的，或者更好的是，在连续监控中观察到的）。然后使用nThreads=nCPUs/loadFactor，希望loadFactor不是零。

您还可以使用较小的coresize和较大的poolsize，但接下来需要一个有界队列。如果队列已满，则本例中的TPE将启动新线程，直到达到池大小。如果您的大多数作业都是在coresize中处理的，那么线程创建不应该太频繁，开销也不应该是一个问题。但即使这样，当TPE运行其最大线程数时，最终也可能会阻塞。

如果您的作业是某种传入的工作，例如从其他连接的套接字读取，而该套接字不能阻止，那么您可以创建一个无边界的中间队列，以释放入站处理，使其最终不会在您的TPE上阻塞，并使用另一个线程将作业从中间提交到TPE队列。

Answer 2

您可以拨打：

thpool.prestartAllCoreThreads();

或

thpool.prestartCoreThread();

这两种方法启动一个核心线程（线程），使其无所事事地等待工作。

但我建议不要这样做，这将直接占用您的资源。

Answer 3

要在启动时修复600个线程，请尝试使用java。util。同时发生的遗嘱执行人。newFixedThreadPool（600）；

创建一个线程池，该线程池重用在共享无界队列上运行的固定数量的线程。在任何时候，最多n个线程将是活动的处理任务。如果在所有线程都处于活动状态时提交其他任务，则它们将在队列中等待，直到有线程可用。如果任何线程在关机之前的执行过程中由于故障而终止，那么如果需要执行后续任务，将替换一个新线程。池中的线程将一直存在，直到显式关闭。

如您所见，留档不会告诉我们线程是立即启动还是按需启动。

如果您想要启动时启动的600个线程，可以发布600个空任务：

for( int i = 0; i < 600; ++i ) {
   executor.submit( new Runnable(){public void run(){/**/}});
}