本篇主要介绍了Java语言开发入门到精通--Java 中的中断机制，通过具体的内容展现，希望对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进程卡掉吧。

✅  扫码免费获取IT基础课程 · IT技术干货 · 答疑解惑 · 职业测评