当有等待线程时如何优雅地降级程序？

Question

我知道优雅地终止线程的构造：

public class Foo implements Runnable {
   private volatile boolean stop = false;

   public void stop() {
      stop = true;
   }

   public void run() {
      while (!stop) {
         ...
      }
   }
}

但是如果某个线程正在某个对象内等待某些东西（使用wait()，没有时间限制），那么这个构造对于停止没有用这个线程，因为他已经超过了 while 循环中的条件，所以他将永远继续下去。

那么，停止等待线程的正确方法是什么？

Answer 1

如果线程实际上在等待某些东西，您应该调用方法Thread.interrupt() 中断线程。不要在 while 循环中检查自定义变量，而是使用 Thread.isInterrupted() 或 Thread.interrupted() - 一个会重置中断标志，另一个则不会。

如果您正在等待某些事情，我假设您必须捕获 InterruptedException，不是吗？

Answer 2

如果您不希望线程无限期地等待，那么首先不要对它们进行编码。你正在编写他们的代码，所以编写它来完成你实际要做的事情，这样你就不必尝试从外部修复它。

Answer 3

每个表现良好的阻塞方法都会声明一个受检查的异常InterruptedException，它的确切目的是：通知线程在被阻塞时已被中断。

您必须捕获此异常，实际上这可以替换您的 stop 字段。

例如，让我们考虑一个日志系统，它会将消息写入专用线程上的文件（这样，花在 IO 上的时间就不会干扰您的应用程序——假设它不是 IO 密集型的应用程序）。

每个线程都有一个可通过 Thread.currentThread().isInterrupted() 读取的中断标志。您可以尝试如下操作：

class Logger {
  private final File file = ...;
  private final BlockingQueue<String> logLines = new LinkedBlockingQueue<String>();
  private final Thread loggingThread = new Thread(new Runnable(){
    @Override public void run() {
      PrintWriter pw;
      try {
        pw = new PrintWriter(new BufferedOutputStream(new FileOutputStream(file)));
        while (!Thread.currentThread().isInterrupted()) {
          try {
            pw.println(logLines.take());
          } catch (InterruptedException e) {
            Thread.currentThread().interrupt(); // good habit: make sure the interrupt status is set
          }
        }
        pw.flush();
        pw.close();
      } catch (IOException e) { ... flush and close pw if not null and open ... }
    }
  });
  { loggingThread.start(); }
  public void log(final String line) { logLines.offer(line); } // will always work, because logLines is a LinkedBQ.
  public void stop() { loggingThread.interrupt(); }
}

最后，为了正常关闭应用程序，您必须确保在关闭 JVM 之前终止该线程。为此，您必须绝对确定在以任何可能的方式关闭之前调用 stop()，或者您可以通过向类中添加类似以下实例初始值设定项的内容来注册关闭挂钩

class Logger {
  ...
  {
    Runtime.getRuntime().addShutdownHook(new Thread(new Runnable() {
      @Override public void run() { close(); }
    }));
  }
}

：将强制 JVM 在终止之前调用 close() （因此中断线程、刷新并关闭文件）。

Answer 4

这一切都取决于您为什么必须在线程中等待。如果线程正在等待不可中断的IO，那么你可以看看停止/中断线程在等待来自套接字的输入时被阻塞

否则，这完全取决于您在线程中的等待方式。您可以使用 wait(1000)，然后检查该标志并再等待一段时间。您可以等待来自阻塞队列的消息，可以使用锁/条件，甚至等待/通知也可以在这种情况下工作，您需要正确处理中断。