我正在尝试诊断使用 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()
最佳答案
当线程池中的线程抛出异常时,它确实会被新的线程替换。但是它不会重试相同的操作。仅当需要执行更多任务时,才会发生替换,以便线程池可以继续执行其工作。
通常,当线程以这种方式终止时,会记录堆栈跟踪,但异常可能会被吞没在某个地方。您可以尝试在发送代码周围添加一个 try-catch block 并显式记录任何异常以进一步分析问题。
不调用shutdown
就可以了。
关于Java newFixedThreadPool 解释,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/43536984/