java - 抛出 TaskRejectedException 且线程池未满

Question

我使用 Spring 线程池来管理项目中的线程。 但是当我的代码运行时出现了一些问题。 我收到如下异常:

org.springframework.core.task.TaskRejectedException: Executor [java.util.concurrent.ThreadPoolExecutor@4cfc01ab[Running, pool size = 200, active threads = 0, queued tasks = 40, completed tasks = 7990]] did not accept task: java.util.concurrent.FutureTask@6ba9fcd5

当池“Activity 线程”为零时，它会抛出TaskRejectedException。

我已经阅读了 Spring 的文档和源代码，但一无所获。

我的 TaskExecutor 类:

@Bean
public ThreadPoolTaskExecutor taskExecutor() {
    ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
    taskExecutor.setKeepAliveSeconds(200);
    taskExecutor.setCorePoolSize(200);
    taskExecutor.setMaxPoolSize(200);
    taskExecutor.setQueueCapacity(40);
    taskExecutor.setRejectedExecutionHandler(new 
    ThreadPoolExecutor.AbortPolicy());
    return taskExecutor;
}

Activity 线程 有时是 0 有时是 10 ，从来没有 200 ，很奇怪。

Answer 1

在异常消息中，它具有“排队任务 = 40”。由于在您的设置中设置了 setQueueCapacity(40)，因此当排队任务已达到 40 时执行线程将引发该异常。

如果您提交任务的速度非常快，我会尝试增加队列容量。线程不会立即从队列移动到 Activity 状态，尤其是当 JVM 繁忙时。

就 Activity 线程数而言，这只是一个近似值。 ThreadPoolExecutor.getActiveThreadCount 的 Java 文档:

/**
 * Returns the approximate number of threads that are actively
 * executing tasks.
 *
 * @return the number of threads
 */
public int getActiveCount() {