使用中断 Java Runnable 并运行清理的首选方法是什么？

Question

这里有关于设计的一般问题。我有一些线程需要在后台保持运行，基本上是一些数据库上传/故障处理任务。都具有以下流模式：

public class Worker implements Runnable {
    private AtomicBoolean isAlive = new AtomicBoolean(true);
    ....
    public void run() {
        while (isAlive.get()) {

            // do some work here, slightly heavy

            if (Thread.interrupted()) {
                // checking Thread.interrupted() as the code above
                // can take a while and interrupt may happen before 
                // it gets here.
                isAlive.setBoolean(false);
                break; // to exit faster
            }

            try { Thread.sleep(sleepTime); } 
            catch (InterruptedException e) {
                isAlive.setBoolean(false);
                break; // to exit faster
            }
        }

        cleanUp(); // e.g. close db connections etc
     }
}

现在我希望能够中断线程，以便它可以优雅地跳出 while 循环并运行 cleanUp() 方法。

有很多方法可以做到这一点，这里列举几个：

1. 在Threads 中关闭Runnables，然后使用interrupt() 方法：

   List<Thread> threadList =...
   for (int i < 0; i < threadCount; i++) {
       Thread t = new Thread(new Worker());
       threadList.add(t);
       t.start()
   }
   
   // later
   for (Thread t : threadList) { t.interrupt(); }
   

2. ThreadPoolExecutor，然后使用shutdownNow():

   ThreadPoolExecutor executor = new ....;
   executor.execute(new Worker()); 
   
   // some lines else later
   executor.shutdownNow();  // shutdown() doesn't interrupt?
   

处理此类工作流的方法是什么？为什么？欢迎所有想法。

Answer 1

总的来说，我个人认为将isAlive 设置为false 是最干净的。 据我所知，interrupt() 是原生代码，这本身就是一个远离的原因。

不要忘记将boolean 设置为volatile。

Answer 2

我认为这两种方法都是可以接受的。如果您有很多线程，我会使用线程池方法以便于管理。如果你只有一个（也许两个）线程，我会单独中断它们。

正如 MouseEvent 所说，不使用中断并使用 isAlive 变量会更干净（这在您的实现中似乎毫无意义）。但是，这意味着您需要关闭或关闭每个实例（仍然是一个好方法）

另外，我会将整个方法包含在 try-catch-finally 语句中，您可以在其中捕获中断并在 finally 子句中进行清理。