中断机制

1. 简介

一个线程不应该由其他线程来强制中断或停止，而是应该由线程自己自行停止，自己来决定自己的命运。所以，Thread.stop(),Thread.suspend(),Thread.resume()都已经被废弃了。在Java中没有办法立即停止一条线程，然而停止线程却显得尤为重要，如取消一个耗时操作。因此，Java提供了一种用于停止线程的协商机制--中断，也即中断标识协商机制。
中断只是一种协作协商机制，Java没有给中断增加任何语法，中断的过程完全需要程序员自己实现。若要中断一个线程，你需要手动调用该线程的interrupt方法，该方法也仅仅是将线程对象的中断标识设成true;接着你需要自己写代码不断地检测当前线程的标识位，如果为true，表示别的线程请求这条线程中断，此时究竟该做什么需要你自己写代码实现。
每个线程对象中都有一个中断标识位，用于表示线程是否被中断;该标识位为true表示中断，为false表示未中断;通过调用线程对象的interrupt方法将该线程的标识位设为true;可以在别的线程中调用，也可以在自己的线程中调用。

2. 中断API

2.1 interrupt()

实例方法，不返回数据。仅仅是设置线程的中断状态为true，发起一个协商而不会立刻停止线程。

2.2 interrupted()

静态方法，返回boolean值，调用方式：Thread.interrupted(), 判断线程是否被中断并清除当前中断状态。返回布尔值该方法执行有两个步骤：
1 返回当前线程的中断状态，测试当前线程是否已被中断。
2. 将当前线程的中断状态清零并重新设为false，清除线程的中断状态。

如果连续两次调用此方法，则第二次调用将返回false，因为连调用两次的结果可能不一样。

2.3 isInterrupted()

实例方法，返回boolean值，判断当前线程是否被中断(通过检查中断标志位)

3. 中断线程实操

3.1 使用volatile变量实现

public class DemoApplicationTests {
	volatile boolean isStop = false;
    @Test
    public void testVolatile(){
        Thread t1 = new Thread(()->{
            while(true){
                if(!isStop){
                    System.out.println("正在执行中。。。。");
                }else{
                    break;
                }
            }
        });
        t1.start();
        System.out.println("默认中断状态是："+t1.isInterrupted());
        new Thread(()->{
            isStop = false;
            System.out.println("更改t1的中断状态");
        }).start();
    }
}

3.2 通过AtomicBoolean实现

public class DemoApplicationTests {
    AtomicBoolean atomiciStop = new AtomicBoolean(false);
    @Test
	public void testAtomicBoolean(){
		Thread t1 = new Thread(()->{
			while(true){
				if(!atomiciStop.get()){
					System.out.println("正在执行中。。。。");
				}else{
                    break;
                }
			}
		});
		t1.start();
		System.out.println("默认中断状态是："+t1.isInterrupted());
		new Thread(()->{
			atomiciStop.set(true);
			System.out.println("更改t1的中断状态");
		}).start();
	}
}

3.3 通过中断api实现

public class DemoApplicationTests {
    @Test
	public void testInterrupted(){
		Thread t1 = new Thread(()->{
			while(true){
				if(!Thread.currentThread().isInterrupted()){
					System.out.println("正在执行中。。。。");
				}else{
                    break;
                }
			}
		});
		t1.start();
		// t1.interrupt(); 通过自身中断
		System.out.println("默认中断状态是："+t1.isInterrupted());
		new Thread(()->{
			t1.interrupt();
			System.out.println("更改t1的中断状态");
		}).start();
	}
}

4. 中断线程须知

1. 如果线程处于正常活动状态，那么会将该线程的中断标志设置为true，仅此而己。被设置中断标志的线程将继续正常运行，不受影响。所以，interrupt()并不能真正的中断线程，需要被调用的线程自己进行配合才行。
2. 如果线程处于被阻塞状态(例如处于sleep,wait,join等状态)，在别的线程中调用当前线程对象的interrupt()方法那么线程将立即退出被阻塞状态, 清除中断标志位，并抛出一个InterruptedException异常。