我有一个长期运行的线程,使用org.

springframework.scheduling.commonj.WorkManagerTaskExecutor创建

使用

Spring并在Websphere Application Server 8中运行.

问题是即使应用程序已停止,此线程仍会继续运行.该线程也需要停止,但它没有发生.我甚至尝试使用Thread.currentThread().isInterrupted()来检查当前线程是否被中断但它总是返回false.所以没有办法通过我的代码知道线程应该继续运行还是停止.

这是我对WorkManagerTaskExecutor的弹簧配置：

线程正在以这种方式执行：

Thread t = new EmailReaderThread(email);

workManagerTaskExecutor.execute(t);

>我错过了什么？

>我能做什么,以便每当应用程序停止时,应用程序的线程(由应用程序生成的线程)也会停止？

我认为这不被视为非托管线程,因为我使用适当的WorkManager注册线程,容器由JNDI作为资源公开.

更新：

这是创建Thread的代码.

@Service

@Transactional

public class SmsServiceHypermedia implements SmsService {

@Autowired

private WorkManagerTaskExecutor workManagerTaskExecutor;

public SmsServiceHypermedia() {

createEmailReaderThread();

}

private void createEmailReaderThread() {

log.debug("Generating Email Reader Threads...");

Email email = getDefaultEmail(); //obtain the default Email object, not important for the problem.

EmailReaderThread r = new EmailReaderThread(email);

workManagerTaskExecutor.execute(r);

}

private class EmailReaderThread extends Thread {

private Email email;

private Session session;

public EmailReaderThread(Email email) {

this.email = email;

}

@Override

public void run() {

readEmails();

}

public void readEmails() {

final long delay = 30 * 1000; //delay between message poll.

log.debug("Starting to read emails for email: " + email.getAddress());

while(!Thread.currentThread().isInterrupted()) {

try {

log.debug("Current session: " + session);

Store store = session.getStore();

log.debug("Connecting using session: " + session);

store.connect();

Folder inbox = store.getFolder("INBOX");

inbox.open(Folder.READ_WRITE);

javax.mail.Message[] messages = inbox.search(

new FlagTerm(new Flags(Flags.Flag.SEEN), false));

for (javax.mail.Message message : messages) {

//Do something with the message

}

inbox.close(true);

store.close();

block(delay);

} catch (Exception e) {

throw new RuntimeException(e);

}

}

}

//I know this could be implemented by calling Thread.sleep() is just that I ran out of options so I also tried it this way.

private void block(long millis) {

final long endTime = System.currentTimeMillis() + millis;

log.debug("Blocking for this amount of time: " + millis + " ms");

while (System.currentTimeMillis() < endTime) {

}

log.debug("End of blocking.");

}

}

}