Java newFixedThreadPool 解释

Question

我正在尝试诊断使用 WSO2 身份管理时遇到的问题。

package org.wso2.carbon.identity.mgt;

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

/**
 * email sender this creates a new task in thread pool for each email sending request
 */
public class NotificationSender {

    private static ExecutorService threadPool = Executors.newFixedThreadPool(5);
    NotificationSendingModule module;

    /**
     * creates and submits a task to the thread pool
     *
     * @param module email sending module as task
     */
    public void sendNotification(NotificationSendingModule module) {

        threadPool.submit(module);
    }

    public NotificationSendingModule getModule() {
        return module;
    }
}

我正在对用户创建过程进行负载测试，当 WSO2 发送用户凭据配置邮件时，它会将多个邮件发送到同一电子邮件地址，即使它们是唯一的。

我从未使用过 Java，但熟悉 C#，因此能够毫无问题地阅读代码，我的问题是:

在 Java 文档中，它提到“如果线程在执行期间和关闭之前由于失败而终止，则会创建一个新线程来取代它。”

这是否意味着如果电子邮件发送遇到错误，那么新线程将再次开始该过程？

我认为发送电子邮件可能出错，因此创建了一个新线程，但无论如何，日志记录都不会与结果绑定(bind)。

另外，从不打电话可以吗

threadPool.shutdown()

Answer 1

当线程池中的线程抛出异常时，它确实会被新的线程替换。但是它不会重试相同的操作。仅当需要执行更多任务时，才会发生替换，以便线程池可以继续执行其工作。

通常，当线程以这种方式终止时，会记录堆栈跟踪，但异常可能会被吞没在某个地方。您可以尝试在发送代码周围添加一个 try-catch block 并显式记录任何异常以进一步分析问题。

不调用shutdown就可以了。