为什么要同时使用布尔值 AND interrupt() 来表示线程终止?

Ste*_*hen 5 java multithreading

我在https://docs.oracle.com/javase/7/docs/technotes/guides/concurrency/threadPrimitiveDeprecation.html中阅读了有关结束线程的方法,这是我从问题How do you kill a Java中的线程?

在第一个链接中,他们首先讨论使用volatile变量向要终止的线程发出信号。线程应该检查此变量并在变量具有表示停止的值时停止操作(例如,如果是null)。因此,要终止线程,您需要将该变量设置为null.

然后他们讨论添加中断来帮助处理长时间阻塞的线程。他们给出了以下 stop() 方法示例,该方法将 volatile 变量(waiter)设置为 null,然后还引发中断。

public void stop() {
    Thread moribund = waiter;
    waiter = null;
    moribund.interrupt();
}
Run Code Online (Sandbox Code Playgroud)

我只是想知道,为什么你需要两者?为什么不只使用interrupt(),然后正确处理呢?这对我来说似乎是多余的。

Nat*_*hes 5

(第一部分是一般性的,可以说我没有注意问题的具体细节。跳到最后部分,查看解决问题中讨论的技术规范的部分。)

\n\n

没有很好的技术原因。这部分是由于人类的局限性,部分是由于令人困惑的 API 设计。

\n\n

首先考虑应用程序开发人员\xe2\x80\x99 的首要任务是创建解决业务问题的工作代码。彻底学习像这样的低级 API 会在急于完成工作的过程中迷失方向。

\n\n

其次,当你学习东西时,\xe2\x80\x99 会倾向于达到一个足够好的状态,然后就留在那里。诸如线程和异常处理之类的内容是被忽视的书后主题。中断是线程书籍的书后主题。

\n\n

现在想象一下,一个代码库由多个具有不同技能水平和对细节的关注度不同的人工作,他们可能会忘记从等待和睡眠中抛出 InterruptedException 会重置中断标志,或者 interrupted 与 isInterrupted 不同,或者InterruptedIoException 也会重置中断标志。如果您有一个捕获 IOException 的 finally 块,您可能会错过 InterruptedException 是 IOException 的子类,并且您可能会错过恢复中断标志的机会。也许匆忙的人们决定管它去死,我不能指望这个中断标志

\n\n

这样对吗?不。

\n\n
    \n
  • 手卷标志不能像中断那样帮助短路等待或睡眠。

  • \n
  • Java 5 并发工具期望任务使用中断来取消。执行者希望提交给他们的任务能够检查中断情况,以便优雅地退出。您的任务可能会使用其他组件,例如阻塞队列。该队列需要能够响应中断,使用它的东西需要知道中断。handrolled 标志对此不起作用,因为 java 5 类无法了解它。

  • \n
\n\n

必须使用中断,因为您\xe2\x80\x99正在使用期望它的工具,但由于难以管理的技术细节而对标志值没有信心,将导致这种代码。

\n\n

(咆哮结束,现在实际响应特定的技术规范示例)

\n\n

好的,请特别查看这篇技术指南文章。有三件事很突出:

\n\n

1)它根本没有利用中断,除了缩短睡眠时间。然后它只是压制异常,而不会费心恢复标志或检查它。您可以使用 InterruptedException 通过在 while 循环之外捕获它来终止,但这不是它的作用。这似乎是一种奇怪的方法。

\n\n

2) 随着示例的充实,很明显该标志用于打开和关闭等待。有人可能会为此使用中断,但这不是惯用的。所以在这里有一个标志是可以的。

\n\n

3) 这是技术指南中的一个玩具示例。并非所有 Oracle 内容都像技术规范或 API 文档一样具有权威性。有些教程有错误陈述或不完整。之所以这样编写代码,可能是因为作者认为读者不会熟悉中断的工作原理,最好尽量减少它的使用。众所周知,技术作家会做出这样的选择。

\n\n

如果我重写它以使用中断,我仍然会保留该标志;我将使用中断来终止,并使用该标志来实现挂起/恢复功能。

\n


sta*_*tut 1

请参阅此文档。您的线程应该检查thread.isInterrupted()状态,例如:

Thread myThread = new Thread()  {
    @Override
    public void run() {
        while (!this.isInterrupted()) {
            System.out.println("I'm working");
            try {
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                //We would like also exit from the thread
                return;
            }
        }
    }
};
Run Code Online (Sandbox Code Playgroud)

当你想停止线程时,你应该调用

myThread.interrupt();
Run Code Online (Sandbox Code Playgroud)

此外,我们可以使用静态方法Thread.interrupted()来检查状态,但之后该方法会清除它,您必须再次调用myThread.interrupt()才能再次设置状态。但我不建议使用Thread.interrupted()方法。

这种方法有助于优雅地停止线程。

所以我也看不出有任何理由使用额外的volatile变量。

volatile可以通过 @lexicore 的答案中的附加标志来达到相同的行为,但我认为这是多余的代码。