Java并发编程初级篇(五)：线程中断

在Java API中，提供了关于线程中断的两个方法。Thread.interrupt()方法会给线程设置一个中断状态，Thread.interrupted()则用来判断中断状态。

下面咱们来看一个例子：

定义一个线程类，咱们在run()方法中定义一个循环来判断线程中断状态，一旦线程中断状态为true，结束线程并打印中断信息。

public class Task implements Runnable {
    @Override
    public void run() {
        System.out.printf("%s: I am starting work.\n", Thread.currentThread().getName());
        try {
            while (true) {
                if (Thread.interrupted()) throw new InterruptedException();
            }
        } catch (InterruptedException e) {
            System.out.printf("%s: I am interrupted.\n", Thread.currentThread().getName());
        }
    }
}

定义主方法类，在主方法类中咱们启动这个线程并持续一段时间后设置这个子线程线程的中断状态。

public class Main {
    public static void main(String[] args) {
        Task task = new Task();
        Thread thread = new Thread(task);
        thread.start();
        try {
            TimeUnit.SECONDS.sleep(5);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        System.out.printf("%s: Setting interrupt flag.\n", Thread.currentThread().getName());
        thread.interrupt();
    }
}

查看控制台日志你会发现，在主线程中设置子线程中断状态后，子线程终止执行。

Thread-0: I am starting work.
main: Setting interrupt flag.
Thread-0: I am interrupted.