ScheduledThreadPoolExecutor 的理想 corePoolSize 是多少？

Question

在我的 Java Web 应用程序中，我使用 ScheduledThreadPoolExecutor 定期检查数据库连接状态。这适用于每个经过身份验证的用户（每个身份验证）。

ScheduledThreadPoolExecutor executor = new ScheduledThreadPoolExecutor(0);

Runnable task = new Runnable() {
     public void run() {
          //check the status of the database connection, and log the result
     }
};

        
executor.scheduleWithFixedDelay(task, 0, 10, TimeUnit.MINUTES);

但是，当 corePoolSize = 0 时，ScheduledThreadPoolExecutor 会消耗 100% CPU。设置 corePoolSize = 1，可以解决问题。

ScheduledThreadPoolExecutor executor = new ScheduledThreadPoolExecutor(1);

在生产中，我们将拥有数百名用户。 我的问题是，在这种情况下，corePoolSize 的理想值是多少？

Answer 1

定期检查数据库连接状态

此轮询是作为健康检查还是您在滚动您自己的数据库连接池？

但是，当 corePoolSize = 0 时，ScheduledThreadPoolExecutor 会消耗 100% CPU。设置 corePoolSize = 1，可以解决问题。

您是如何确定这一点的？您可以检查 VisualVM 中的线程视图，但即使所有这些线程都在运行，JVM 也从未超过 3% 的 CPU 使用率。值得注意的是，线程池线程大多处于停放状态。

在生产中，我们将拥有数百名用户。我的问题是，在这种情况下，corePoolSize 的理想值是多少？

您正在启动多少个线程池？每个身份验证一个是非常低效的。与连接相同。就像我之前提到的，您通常希望将它们汇集在一起​​。您如何在“身份验证”的整个生命周期中保持连接打开？您是否将连接存储在HttpSession 中，即request.getSession()？这是一个坏主意，因为与连接相关的开销很大，而且很容易出现清理问题。

您是否有共享池并且您没有停止旧任务？这可能会占用 CPU。

综上所述，线程池的一般规则是threads=qps*latency，所以如果你每10s检查一次连接，检查连接需要1s，你有60个连接，你需要6个线程+净空。阅读您的示例，这似乎不是您的问题。听起来您正在启动太多线程池并可能泄漏它们。