Java面试interrupt

jiezi

5 年前

我们都知道，Java 中停止一个线程不能用 stop，因为stop 会瞬间强行停止一个线程，且该线程持有的锁并不能释放。大家多习惯于用interrupt，那么使用它又有什么需要注意的呢？
<!– more –>

Java 中和 interrupt 相关的方法有三个

public boolean isInterrupted()

public void interrupt()

public static boolean interrupted()

每个线程都一个状态位用于标识当前线程对象是否是中断状态。isInterrupted主要用于判断当前线程对象的中断标志位是否被标记了，如果被标记了则返回 true，表示当前已经被中断，否则返回 false。我们也可以看看它的实现源码：

    public boolean isInterrupted() {return isInterrupted(false);
    }

    private native boolean isInterrupted(boolean ClearInterrupted);

底层调用的 native 方法 isInterrupted，传入一个 boolean 类型的参数，用于指定调用该方法之后是否需要清除该线程的中断标识位。从这里我们也可以看出来，调用isInterrupted() 并不会清除线程的中断标识位。

interrupt()用于设置当前线程对象的中断标识位，其源码为：

    public void interrupt() {
        // 检查当前线程是否有权限修改目标线程，如果没有，则会抛出异常 SecurityException
        if (this != Thread.currentThread())
            checkAccess();

        synchronized (blockerLock) {
            Interruptible b = blocker;
            if (b != null) {interrupt0();           // Just to set the interrupt flag
                b.interrupt(this);
                return;
            }
        }
        interrupt0();}

blockerLock和 blocker 都和阻塞 IO 时产生的中断相关，因此推测 interrupt() 需要当阻塞 IO 操作执行完之后，才可以执行。

interrupt()其实只是改变了一个标志位，对于线程本身的状态并没有影响。

该方法是一个静态的方法，用于返回当前线程是否被中断，其源码是：

    public static boolean interrupted() {return currentThread().isInterrupted(true);
    }

需要注意的是：该方法调用结束的时候会清空中断标识位。

我们知道，Java 中的线程一共 6 种状态，分别是NEW，RUNNABLE，BLOCKED，WAITING，TIMED_WAITING，TERMINATED（Thread 类中有一个 State 枚举类型列举了线程的所有状态）。下面我们就将把线程分别置于上述的不同种状态，然后看看中断操作对它们的影响。

NEW状态表示线程还未调用 start() 方法，TERMINATED状态表示线程已经运行终止。

这两个状态下调用中断方法来中断线程的时候，Java 认为毫无意义，所以并不会设置线程的中断标识位。例如：

NEW状态：

public static void main(String[] args) {Thread thread = new Thread();
    System.out.println(thread.getState());

    System.out.println(thread.isInterrupted());
    thread.interrupt();
    System.out.println(thread.isInterrupted());
}

输出结果：

NEW
false
false

TERMINATED状态：

public static void main(String[] args) throws InterruptedException {Thread thread = new Thread();
    // 开始线程
    thread.start();
    // 等待线程结束
    thread.join();
    System.out.println(thread.getState());

    System.out.println(thread.isInterrupted());
    thread.interrupt();
    System.out.println(thread.isInterrupted());
}

输出结果：

TERMINATED
false
false

从上述的两个例子来看，处于 NEW 和TERMINATED状态的线程，对于中断是屏蔽的，也就是说中断操作对这两种状态下的线程是无效的。

处于 RUNNABLE 状态的线程，当中断线程后，会修改其中断标志位，但并不会影响线程本身。例如：

/**
 * 自定义线程类
 */
public class MyThread extends Thread{

    @Override
    public void run(){while(true){// 什么都不做，就是空转}
    }

    public static void main(String[] args) {Thread thread = new MyThread();
        thread.start();
        System.out.println(thread.getState());

        System.out.println(thread.isInterrupted());
        thread.interrupt();
        System.out.println(thread.isInterrupted());

        System.out.println(thread.getState());
    }
}

结果为：

RUNNABLE
false
true
RUNNABLE

中断标志位确实被改变了，但线程依旧继续运行。那我们调用 interrupt() 方法的意义在哪儿？

其实 Java 是将中断线程的权利交给了我们自己的程序，通过中断标志位，我们的程序可以通过 boolean isInterrupted() 方法来判断当前线程是否中断，从而决定之后的操作。

我们可以在此基础上，保证执行任务的原子性。例如修改 MyThread 类的方法：

/**
 * 自定义线程类
 */
public class MyThread extends Thread{

    @Override
    public void run(){while(true){if (this.isInterrupted()){System.out.println("exit MyThread");
                break;
            }
        }
    }

    public static void main(String[] args) throws InterruptedException {Thread thread = new MyThread();
        thread.start();
        System.out.println(thread.getState());

        System.out.println(thread.isInterrupted());
        thread.interrupt();
        System.out.println(thread.isInterrupted());

        thread.join();
        System.out.println(thread.getState());
    }
}

结果为：

RUNNABLE
false
true
exit MyThread
TERMINATED

当线程处于 BLOCKED 状态，说明该线程由于竞争某个对象的锁失败而被挂在了该对象的阻塞队列上了。

那么此时发起中断操作不会对该线程产生任何影响，依然只是设置中断标志位。例如：

/**
 * 自定义线程类
 */
public class MyThread extends Thread{public synchronized static void doSomething(){while(true){// 空转}
    }
    @Override
    public void run(){doSomething();
    }

    public static void main(String[] args) throws InterruptedException {
        // 启动两个线程
        Thread thread1 = new MyThread();
        thread1.start();
        Thread thread2 = new MyThread();
        thread2.start();

        Thread.sleep(1000);
        System.out.println(thread1.getState());
        System.out.println(thread2.getState());

        System.out.println(thread2.isInterrupted());
        thread2.interrupt();
        System.out.println(thread2.isInterrupted());
        System.out.println(thread2.getState());
    }
}

结果为：

RUNNABLE
BLOCKED
false
true
BLOCKED

thread2 处于 BLOCKED 状态，执行中断操作之后，该线程仍然处于 BLOCKED 状态，但是中断标志位却已被修改。

这种状态下的线程和处于 RUNNABLE 状态下的线程是类似的，给了我们程序更大的灵活性去判断和处理中断。

这两种状态本质上是同一种状态，只不过 TIMED_WAITING 在等待一段时间后会自动释放自己，而 WAITING 则是无限期等待，需要其他线程调用类似 notify 方法释放自己。但是他们都是线程在运行的过程中由于缺少某些条件而被挂起在某个对象的等待队列上。

当这些线程遇到中断操作的时候，会抛出一个 InterruptedException 异常，并清空中断标志位。例如：

/**
 * 自定义线程类
 */
public class MyThread extends Thread{

    @Override
    public void run(){synchronized (this){
            try {wait();
            } catch (InterruptedException e) {System.out.println("catch InterruptedException");

            }
        }
    }

    public static void main(String[] args) throws InterruptedException {Thread thread = new MyThread();
        thread.start();

        Thread.sleep(1000);
        System.out.println(thread.getState());

        System.out.println(thread.isInterrupted());
        thread.interrupt();
        Thread.sleep(1000);
        System.out.println(thread.isInterrupted());
    }
}

结果为：

WAITING
false
catch InterruptedException
false

从运行结果看，当线程启动之后就被挂起到该线程对象的等待队列上，然后我们调用 interrupt() 方法对该线程进行中断，输出了我们在 catch 中的输出语句，显然是捕获了 InterruptedException 异常，接着就看到该线程的中断标志位被清空。

因此我们要么就在 catch 语句中结束线程，否则就在 catch 语句中加上this.interrupt();，再次设置标志位，这样也方便在之后的逻辑或者其他地方继续判断。

我们介绍了线程在不同状态下对于中断请求的反应：

NEW和 TERMINATED 对于中断操作几乎是屏蔽的。
RUNNABLE和 BLOCKED 类似，对于中断操作只是设置中断标志位并没有强制终止线程，对于线程的终止权利依然在程序手中。
WAITING和 TIMED_WAITING 状态下的线程对于中断操作是敏感的，他们会抛出异常并清空中断标志位。

有兴趣的话可以关注我的公众号或者头条号，说不定会有意外的惊喜。

Java面试interrupt

interrupt 相关的方法

boolean isInterrupted()

void interrupt()

boolean interrupted()

线程的状态与中断的关系

NEW 和 TERMINATED

RUNNABLE

BLOCKED

WAITING/TIMED_WAITING

总结