聊聊 Java 中的中断机制

在Java中，用于终止一个正在运行中的线程，并非调用stop方法，而是自行设置一个标志位，在安全点检测标志位，决定是否退出，但也可能会因为线程被挂起，无法走到标志位。因此，Java线程提供了中断机制，Thread类提供了中断线程执行的调用方法：interrupt，用于中断因线程挂起的等待，调用interrupt方法后，线程会被唤醒，待下次cpu调度就会继续执行中断后的代码 。

我们经常会调用Thread#sleep、Object#wait、Queue#poll等方法，并要求我们处理InterruptedException异常。 那么，抛出InterruptedException后，线程会终止吗?

如果不捕获InterruptedException，那么线程就会因为异常终止，是因为异常终止，并不是因为被中断。如果捕获了InterruptedException，那么线程就不会终止。

中断，其实只是jvm用于唤醒因锁竞争、I/O操作、休眠等待被挂起的线程，并设置一个中断标志，我们可以利用这个标志去做一些处理。比如，当我们发送消息给远程服务器，并休眠等待结果时，如果线程被唤醒，并设置了中断标志，此时我们可以知道，并非等到结果被唤醒的，而是被中断唤醒的，可以决定是继续等待结果，还是放弃等待。

xxl-job提供取消任务操作，而任何运行中的线程，都只能利用中断机制去结束线程任务，所以我们想要任务支持被取消，那么在写定时任务时，一定要考虑清楚，是不是应该捕获InterruptedException，如何利用中断标志结束任务，否则将会导致任务无法被取消。

我们来看个案例：

@Test 
public void test() { 
    ExecutorService executorService = Executors.newSingleThreadExecutor(); 
    Future future = executorService.submit(() -> { 
        while (true) { 
            System.out.println( "rung....." ); 
            ThreadUtils.sleep(1000); 
        } 
    }); 
    ThreadUtils.sleep(1000); 
    future.cancel(true); 
    try { 
        future.get(); 
    } catch (InterruptedException | CancellationException | ExecutionException e) { 
        e.printStackTrace(); 
    } 
    ThreadUtils.sleep(1000 * 60); 
} 

此案例创建了只有一个线程的线程池，提交了一个死循序任务，该任务只调用ThreadUtils.sleep方法进入休眠。平常我们调用Thread.sleep方法都要求是否捕获中断异常，很多时候我们都会嫌弃麻烦，就用一个工具类提供sleep方法，然后将中断异常捕获，如ThreadUtils：

public class ThreadUtils { 
    public static void sleep(long millis) { 
        try { 
            Thread.sleep(millis); 
        } catch (InterruptedException ignored) { 
        } 
    } 
} 

此案例中，由于我们捕获了中断异常，因此这会导致任务并不会被终止，只是当我们调用future的get方法时会抛出CancellationException异常，如下图所示。

任务依然在运行中......

因此，在实际开发中，如果我们开发的Job也是如此，将会导致Job无法被中断取消，直至Job执行完成或者重启。在开发Job时，应当合理考虑是否要捕获中断异常。

如果我们希望案例中的任务能够被终止，我们可以这样处理：

@Test 
public void test() { 
    ExecutorService executorService = Executors.newSingleThreadExecutor(); 
    Future future = executorService.submit(() -> { 
        while (true) { 
            System.out.println( "rung....." ); 
            try { 
                Thread.sleep(1000); 
            } catch (InterruptedException ex) { 
                System.err.println( "interrupted" ); 
                return; // 退出死循环 
            } 
        } 
    }); 
    ThreadUtils.sleep(1000); 
    future.cancel(true); 
    try { 
        future.get(); 
    } catch (InterruptedException | CancellationException | ExecutionException e) { 
        e.printStackTrace(); 
    } 
    ThreadUtils.sleep(1000 * 60); 
} 

关于Thread的interrupt方法，注释描述的大致意思如下：

• 如果被中断的线程，当前是调用Object#wait、Thread#join、Thread#sleep方法，将收到InterruptedException，并且会清除中断标志;
• 如果此线程在I/O操作中(指java nio)被阻塞，调用interrupt方法通道将被关闭，线程将收到一个ClosedByInterruptException，并且会设置中断标志;
• ....

怎么理解中断标志呢?

“如果被中断的线程，当前是调用Object#wait、Thread#join、Thread#sleep方法，将收到InterruptedException，并且会清除中断标志”，案例中的代码正好符合这点，如果我们将案例代码改为如下：

@Test 
public void test() { 
    ExecutorService executorService = Executors.newSingleThreadExecutor(); 
    Future future = executorService.submit(() -> { 
        while (!Thread.interrupted()) { 
            System.out.println( "rung....." ); 
            try { 
                Thread.sleep(1000); 
            } catch (InterruptedException ex) { 
                System.err.println( "interrupted" ); 
            } 
        } 
    }); 
    ThreadUtils.sleep(1000); 
    future.cancel(true); 
    try { 
        future.get(); 
    } catch (InterruptedException | CancellationException | ExecutionException e) { 
        e.printStackTrace(); 
    } 
    ThreadUtils.sleep(1000 * 60); 
} 

执行这段代码你会发现，死循环根本没有退出，正是因为Thread#sleep方法被中断，JVM并不会设置中断标志，只是抛出InterruptedException异常。

其它情况下，JVM只会设置中断标志，并不会抛出InterruptedException。如果我们不处理中断信号，那么中断信号并不会影响程序的继续执行。

@Test 
public void test2() { 
    ExecutorService executorService = Executors.newSingleThreadExecutor(); 
    Future future = executorService.submit(() -> { 
        int number = 0; 
        while (!Thread.interrupted()) { 
            number++; 
        } 
        System.out.println(number); 
    }); 
    ThreadUtils.sleep(1000); 
    future.cancel(true); 
    try { 
        future.get(); 
    } catch (InterruptedException | CancellationException | ExecutionException e) { 
        e.printStackTrace(); 
    } 
    ThreadUtils.sleep(1000 * 60); 
} 

 

此案例并没有I/O操作导致的阻塞，因为调用中断方法后，线程只是设置了中断标志，我们用中断标志作为循序的退出条件，运行此案例，我们将看到，线程中断后，任务终止。反之，如果我们不处理中断标志，那么就等着IDEA进程卡掉吧。