尽管线程可用，但任务被拒绝

Question

我面临一个奇怪的情况，我有一个线程池，maxPoolSize 为 100，队列大小为 30，corePoolSize 为 50。应用程序重新启动一段时间后，我可以在日志中看到 RejectedExecution 错误，即使线程是可用，任务被拒绝。

org.springframework.core.task.TaskRejectedException: Executor [java.util.concurrent.ThreadPoolExecutor@593a81ea[Running, pool size = 100, active threads = 3, queued tasks = 17, completed tasks = 57463]]

我多次进行线程转储，发现这个池的线程正在执行Timed_Waiting。上面的日志是正确的，根据转储也只有 3 个可运行，但我无法理解为什么其余 97 个线程对系统不可用。以下是 97 个线程常见的线程转储：

YYYThreadPoolExecutor-100" #6414 prio=5 os_prio=0 tid=0x00007f0830dce800 nid=0x3a39 waiting on condition [0x00007f064b6b5000]
   java.lang.Thread.State: TIMED_WAITING (parking)
    at sun.misc.Unsafe.park(Native Method)
    - parking to wait for  <0x00007f0a32b21088> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
    at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)

系统是具有 100 GB RAM 的 16 核机器。 16 核的当前 CPU 利用率仅为 103%，RAM 利用率为

即使我也将线程池大小增加到 500，同样的情况也会延迟到来。

以前有人遇到过这种情况吗？ 提前致谢。

Answer 1

参考oracle文档ThreadPoolExecutor

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

使用给定的初始参数和默认线程工厂创建一个新的 ThreadPoolExecutor。

参数：

corePoolSize - 保留在池中的线​​程数，即使它们处于空闲状态，除非设置了 allowCoreThreadTimeOut

maximumPoolSize - 池中允许的最大线程数

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

unit - keepAliveTime 参数的时间单位

workQueue - 用于在执行任务之前保存任务的队列。此队列将仅保存由 execute 方法提交的 Runnable 任务。

handler - 由于达到线程边界和队列容量而阻塞执行时使用的处理程序

根据您提供的详细信息，由于数量庞大，您尚未达到线程池边界，但您可能已达到队列容量。

您不需要高数量的线程数。相反，您可以增加队列容量。

通常队列大小将被配置为更高的值来编号线程池大小。 maximumPoolSize 可以配置为您机器中的 CPU 内核数：Runtime.getRuntime().availableProcessors()