摘要：線程中斷線程中斷就是一種協(xié)作機(jī)制。它并不會(huì)真正的中斷一個(gè)正在運(yùn)行的線程，而只是發(fā)出中斷請(qǐng)求，然后由線程在下一個(gè)合適的時(shí)刻中斷自己。

線程池生命周期包括:

RUNNING:接收新的任務(wù)并處理隊(duì)列中的任務(wù)

SHUTDOWN:不接收新的任務(wù)，但是處理隊(duì)列中的任務(wù)

STOP:不接收新的任務(wù)，不處理隊(duì)列中的任務(wù)，同時(shí)中斷處理中的任務(wù)

TIDYING:所有的任務(wù)處理完成，有效的線程數(shù)是0

TERMINATED:terminated()方法執(zhí)行完畢

轉(zhuǎn)換成TIDYING狀態(tài)的線程會(huì)運(yùn)行terminated方法。執(zhí)行完terminated()方法之后，所有等待在awaitTermination()就會(huì)返回。

轉(zhuǎn)換過程為：

線程池是空的即有效線程數(shù)是0

如果代碼能夠在某個(gè)操作正常完全之前置入“完成”狀態(tài)，那么這個(gè)操作就稱為可取消的。java中提供了協(xié)作式機(jī)制，使請(qǐng)求取消的任務(wù)和代碼遵循一種協(xié)商好的協(xié)議。

線程中斷就是一種協(xié)作機(jī)制。它并不會(huì)真正的中斷一個(gè)正在運(yùn)行的線程，而只是發(fā)出中斷請(qǐng)求，然后由線程在下一個(gè)合適的時(shí)刻中斷自己。
Thread中的中斷方法包括

public void interrupt() {
    if (this != Thread.currentThread())
        checkAccess();//非當(dāng)前線程有可能拋出SecurityException

    synchronized (blockerLock) {
        //用于執(zhí)行可終端的IO操作對(duì)應(yīng)的方法
        Interruptible b = blocker;
        if (b != null) {
            //僅設(shè)置終端標(biāo)記
            interrupt0(); 
            //執(zhí)行實(shí)現(xiàn)了Interruptible接口的防范
            b.interrupt(this);
            return;
        }
    }
    //僅設(shè)置終端標(biāo)記
    interrupt0();
}

調(diào)用它根據(jù)線程的不同場(chǎng)景，有不同的結(jié)果

如果線程阻塞的是一個(gè)可以中斷的channel，那么channel會(huì)被關(guān)閉，同時(shí)線程會(huì)收到j(luò)ava.nio.channels.ClosedByInterruptException，并且會(huì)設(shè)置中斷標(biāo)志

//AbstractInterruptibleChannel中：
protected final void begin() {
        if (interruptor == null) {
            interruptor = new Interruptible() {
                    public void interrupt(Thread target) {
                        synchronized (closeLock) {
                            if (!open)
                                return;
                            open = false;
                            interrupted = target;
                            try {
                            //關(guān)閉channel
                            AbstractInterruptibleChannel.this.implCloseChannel();
                            } catch (IOException x) { }
                        }
                    }};
        }
        blockedOn(interruptor);
        Thread me = Thread.currentThread();
        if (me.isInterrupted())
            interruptor.interrupt(me);
    }

如果線程阻塞在Selector,執(zhí)行它的 wakeup方法，因而selector會(huì)立即返回，同時(shí)會(huì)設(shè)置中斷標(biāo)志

//AbstractSelector中：
protected final void begin() {
    if (interruptor == null) {
        interruptor = new Interruptible() {
                public void interrupt(Thread ignore) {
                    //執(zhí)行wakeup,Selector立即返回
                    AbstractSelector.this.wakeup();
                }};
    }
    AbstractInterruptibleChannel.blockedOn(interruptor);
    Thread me = Thread.currentThread();
    if (me.isInterrupted())
        interruptor.interrupt(me);
}

如果線程阻塞在wait/join/sleep，線程的中斷標(biāo)志會(huì)被清除，并拋出InterruptedException

非上述三種情況，僅設(shè)置中斷標(biāo)志

可以看出調(diào)用interrupt并不意味著立即停止目標(biāo)線程正在進(jìn)行的工作，而只是傳遞了請(qǐng)求中斷的消息

清除當(dāng)前線程的中斷狀態(tài)，并返回之前的值。它實(shí)際執(zhí)行的就是當(dāng)前線程的isInterrupted(true)

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

假設(shè)當(dāng)前線程是中斷的，此時(shí)調(diào)用會(huì)返回true，如果在下次調(diào)用之前沒有中斷，此時(shí)調(diào)用會(huì)返回false

返回目標(biāo)線程的中斷狀態(tài),只有線程狀態(tài)是中斷才會(huì)返回true,其它時(shí)候返回false

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

可以看到interrupted和isInterrupted 調(diào)用的都是isInterrupted方法，只不過參數(shù)不一樣。它的參數(shù)實(shí)際代表的是是否要清除中斷標(biāo)記，為true也就清除，在java中的定義如下

private native boolean isInterrupted(boolean ClearInterrupted);

參考linux上的實(shí)現(xiàn)為
```
bool os::is_interrupted(Thread* thread, bool clear_interrupted) {
  assert(Thread::current() == thread || Threads_lock->owned_by_self(),
    "possibility of dangling Thread pointer");

  OSThread* osthread = thread->osthread();

  bool interrupted = osthread->interrupted();

  if (interrupted && clear_interrupted) {
    osthread->set_interrupted(false); //如果中斷了，并且要清除中斷標(biāo)記，就改變終端標(biāo)記
    // consider thread->_SleepEvent->reset() ... optional optimization
  }

  return interrupted;
}
```

一般策略如下

傳遞異常，使當(dāng)前方法也成為可中斷的

恢復(fù)中斷狀態(tài)，使得調(diào)用棧中的上層代碼能夠?qū)ζ溥M(jìn)行處理

并非所有的可阻塞方法或者阻塞機(jī)制都能響應(yīng)中斷，停止線程的方法類似于中斷

Java.io中的Socket I/O。InputStream和OutputStream中的read和write等不會(huì)響應(yīng)中斷，可以關(guān)閉底層的套接字拋出SocketException

Java.io中的同步I/O。大多數(shù)的標(biāo)準(zhǔn)的channel都實(shí)現(xiàn)了InterruptibleChannel,它內(nèi)部一般都是拋出ClosedByInterruptException,并關(guān)閉鏈路

Selector的異步I/O。阻塞在了Selector.select，通過調(diào)用wakeup或者close來提前返回。

獲取某個(gè)鎖。由于線程等待某個(gè)內(nèi)置鎖，它會(huì)認(rèn)為自己能等到，所以不會(huì)處理中斷，通過Lock的lockInterruptibly可以同時(shí)實(shí)現(xiàn)等待鎖并且響應(yīng)中斷

Thread.stop本身是不安全的。停止一個(gè)線程會(huì)釋放它所有的鎖的監(jiān)視器，如果有任何一個(gè)受這些監(jiān)視器保護(hù)的對(duì)象出現(xiàn)了狀態(tài)不一致，其它的線程也會(huì)以不一致的狀態(tài)查看這個(gè)對(duì)象，其它線程在這個(gè)對(duì)象上的任何操作都是無法預(yù)料的
為什么廢棄了Thread.stop

應(yīng)用程序準(zhǔn)備退出時(shí)，這些服務(wù)所擁有的線程也應(yīng)該結(jié)束。
ExecutorService提供了兩種方法：shutdown和shutdownNow

shutdown在執(zhí)行完隊(duì)列中的所有任務(wù)之后，才關(guān)閉，它并不會(huì)接收新的任務(wù)

shutdownNow則是立馬關(guān)閉正在執(zhí)行的任務(wù)，并返回還沒有開始的任務(wù)