即使在 Java 线程中的 Thread.State 为“TERMINATED”之后,isInterrupted() 仍然返回“false” - 为什么?

问题描述

当线程被终止(Thread.State.TERMINATED)时,它仍然没有被中断。为什么?

我找到了 this,我找到了 this,但都没有回答我的问题。我已经在 OpenJDK 11 和 Oracle JDK 16 上尝试过这个 - 没有区别,结果相同。子>

我已经使用 Java 10 多年了,多线程任务对我来说一直很清楚;然而,不小心,我遇到了一些奇怪的事情(对我来说),我很想知道。

我明白,private volatile boolean interrupted; 只是类 Thread一个标志(字段),我可以将它与 interrupt() 结合使用,以便对案例进行一些逻辑编码当 isInterrupted() 得到 true

但是,为什么 Thread.State.TERMINATED 状态不会也生成相同的线程 interrupted

public class MainClass {

    public static void main(String[] args) throws Exception {
        Thread alfa = new Thread(() -> {
            for (int i = 0; i < 3; i++) {
                System.out.println(i + ". " + Thread.currentThread().getName() + " state: " + Thread.currentThread().getState().name());
                try {Thread.sleep(1000);} catch (Exception e) {}
            }
        });
        alfa.setName("Alfa thread");
        System.out.println(alfa.getName() + " state before invoking .start() is: " + alfa.getState().name());
        alfa.start();
        int i = 0;
        while (true) {
            ++i;
            System.out.println(i + ". " + alfa.getName() + " state: " + alfa.getState().name());
            System.out.println(i + ". " + alfa.getName() + " is interrupted?: " + alfa.isInterrupted());
            Thread.sleep(1000);
        }
    }
}

证明,这:

Alfa thread state before invoking .start() is: NEW
1. Alfa thread state: RUNNABLE
0. Alfa thread state: RUNNABLE
1. Alfa thread is interrupted?: false
1. Alfa thread state: RUNNABLE
2. Alfa thread state: TIMED_WAITING
2. Alfa thread is interrupted?: false
2. Alfa thread state: RUNNABLE
3. Alfa thread state: TIMED_WAITING
3. Alfa thread is interrupted?: false
4. Alfa thread state: TERMINATED //alfa is terminated!
4. Alfa thread is interrupted?: false //alfa is not interrupted. SerIoUsly?
  • 我是不是没有得到一些东西,这是故意这样做的,因为它在幕后有一些想法?或
  • 这只是被忘记正确实施的东西吗?

解决方法

Thread.StateTERMINATED 表示指定的 Thread 已完成执行。 终止的 Thread 不会被中断,您可能将两者混为一谈,这是不同的。

只有当线程被另一个线程通过 isInterrupted() 方法中断时,interrupt() 方法才返回 true。

看看这里: https://docs.oracle.com/javase/tutorial/essential/concurrency/interrupt.html

线程终止并不意味着线程中断,因为它们是两个不同且独立的事物。

编辑:

我在评论中看到你对中断有点困惑,所以我想澄清一下。

因此,基本上中断是对线程的指示,它应该停止当前正在执行的操作,并执行其他操作。因此,被中断的线程不会停止或暂停(因为您使用了恢复一词),但它是一个应该停止正在执行的操作的线程。例如,假设名为 myThread 的线程当前正忙于执行一个非常长的操作,如下所示:

public void reallyLongOperation() throws InterruptedException {
  // the thread will stay in the loop for a long time
  while(!taskFinished){
    //stuff repeated for many cycles
    if(Thread.interrupted()){
      throw new InterruptedException("The really long operation has been interrupted");
    }
  }
}

现在,假设用户想要通过按下 GUI 上的按钮来取消这个非常长的操作。 AWT-EventQueue 线程调用 myThread.interrupt()。现在 myThread 仍在循环中执行操作,但是当线程达到条件时,Thread.interrupted() 清除标志并返回 true,因为它已被中断。 InterruptedException 被抛出,我们必须像处理其他所有受检异常一样处理它。

现在,myThread.isInterrupted()Thread.interrupted() 之间有什么区别?

  • myThread.isInterrupted() 仅在中断标志为真时才返回真。但是,它不会重置标志。
  • Thread.interrupted() 是一个静态方法,和前者一样,如果中断标志为真则返回真,但它也会清除它。

当一个线程死了,并且它从来没有被中断过,或者如果这个标志之前已经被清除过,上面的两种方法都会返回false。

线程中断与线程的状态无关,也与挂起无关。