Java 多线程 BlockingQueue 实现 高并发邮件 代码 SystemEmailSender

package com.pingan.emall.biz.util;

import com.paic.pafa.app.lwc.core.util.DevLog;

public class SystemEmailSender extends Thread {

private boolean running = true;
private SystemEmailBlockingQueue queue;

public SystemEmailSender(SystemEmailBlockingQueue queue) {
this.queue = queue;
}

@Override
public void run() {
while (running) {
try {
MailBean mail = queue.poll();

boolean succeed = SystemEmailUtils.sendMail(mail);
queue.retry(mail,  succeed);
} catch (ThreadDeath e) {
DevLog.error("Thread dead in send mail thread", e);
break;
}
}
}

public void setRunning(boolean running) {
this.running = running;
}

@Override
public void destroy() {
DevLog.info("System mail send thread destroyed");
}

}