Keep-alive如何与ThreadPoolExecutor一起工作？

multithreading java keep-alive

2022-08-31 14:46:22

为了继续我发布的问题，我正在尝试在我的代码库中使用ThreadPoolExecutor。即使反复尝试从Java API文档理解，我也无法清楚地理解要在构造函数中传递的参数背后的功能/目的。希望有人能用一些好的工作例子来解释我。keepAliveTime

摘自 Java 文档：

public ThreadPoolExecutor(int corePoolSize,
                          int maximumPoolSize,
                          long keepAliveTime,
                          TimeUnit unit,
                          BlockingQueue<Runnable> workQueue)

keepAliveTime - 当线程数大于内核时，这是多余的空闲线程在终止之前等待新任务的最长时间。

答案 1

假设内核大小为 5，最大大小为 15。由于某种原因，您的池变得繁忙，并使用所有15个可用线程。最终，您将没有工作要做 - 因此您的某些线程在完成最终任务时会变得空闲。所以其中10个线程被允许死亡。

但是，为了避免它们被过快地杀死，您可以指定保持活动状态的时间。因此，如果指定 1 作为值和值，则每个线程将在完成任务执行后等待一分钟，以查看是否有更多工作要做。如果仍然没有再给它任何工作，它就会让自己完成，直到池中只有5个线程 - 池的“核心”。keepAliveTimeTimeUnit.MINUTEunit

答案 2

以下是Javadoc的更多描述：

<dt>Keep-alive times</dt>
 *
 * <dd>If the pool currently has more than corePoolSize threads,
 * excess threads will be terminated if they have been idle for more
 * than the keepAliveTime (see {@link
 * ThreadPoolExecutor#getKeepAliveTime}). This provides a means of
 * reducing resource consumption when the pool is not being actively
 * used. If the pool becomes more active later, new threads will be
 * constructed. This parameter can also be changed dynamically
 * using method {@link ThreadPoolExecutor#setKeepAliveTime}. Using
 * a value of <tt>Long.MAX_VALUE</tt> {@link TimeUnit#NANOSECONDS}
 * effectively disables idle threads from ever terminating prior
 * to shut down.
 * </dd>
 *

从本质上讲，这只允许您控制空闲池中剩余的线程数。如果你把它做得太小（对于你正在做的事情），你将创建太多的线程。如果将其设置为太大，则会消耗不需要的内存/线程。