我正在实施一项服务,该服务执行一些较长时间运行的任务,此处由Thread.sleep(10000)
模拟。当我按ctrl + c执行时,我从来没有得到我期望的InterruptedException
。我想知道为什么。关闭ScheduledExecutorService安全吗?
package simple;
import my.util.Now;
import io.dropwizard.lifecycle.Managed;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
public class EmailSender implements Managed {
private static final Logger LOGGER = LoggerFactory.getLogger(EmailSender.class);
ScheduledExecutorService executorService = Executors.newScheduledThreadPool(3);
// Constructor
public EmailSender() {}
@Override
public void start() {
LOGGER.info("Starting email sender thread: {}", Thread.currentThread().getName());
Runnable task =() -> {
LOGGER.info("Running: {} in thread: {}", Now.now(), Thread.currentThread().getName());
try {
Thread.sleep(10000);
} catch (InterruptedException ie) {
LOGGER.error("Task is being interrupted: {}", ie.getMessage());
}
};
executorService.scheduleAtFixedRate(task, 0, 5, TimeUnit.SECONDS);
}
@Override
public void stop() {
LOGGER.info("Stopping email sender thread: {}", Thread.currentThread().getName());
executorService.shutdown();
}
}
这样可以安全地假设executorService.shutdown();
等到执行完成任务这样吗?
该文档基本上说明了一切:['关机()'](https://docs.oracle.com/javase/7/ docs/api/java/util/concurrent/ExecutorService.html#shutdown())会阻止执行程序接受新的提交。您可能希望['shutdownNow()'](https://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ExecutorService.html#shutdownNow()),它会中断正在运行的线程。不,后者是不安全的,因为中断线程不是很安全。 – dhke