線程的應用
如何應用多線程
在 Java 中，有多種方式來實作多線程。繼承 Thread 類、實作 Runnable 接口、使用 ExecutorService、Callable、Future 實作帶傳回結果的多線程。
繼承 Thread 類建立線程
Thread 類本質上是實作了 Runnable 接口的一個執行個體，代表一個線程的執行個體。啟動線程的唯一方法就是通過 Thread
類的 start()執行個體方法。start()方法是一個 native 方法，它會啟動一個新線程，并執行 run()方法。這種方式實作多線程很簡單，
通過自己的類直接 extend Thread，并複寫 run()方法，就可以啟動新線程并執行自己定義的 run()方法。
public classMyThread extends Thread {public voidrun() {
System.out.println("MyThread.run()");
}
}
main中執行
MyThread myThread1= newMyThread();
MyThread myThread2= newMyThread();
myThread1.start();
myThread2.start();
實作 Runnable 接口建立線程
如果自己的類已經 extends 另一個類，就無法直接 extends
Thread，此時，可以實作一個 Runnable 接口
public classMyThread extends OtherClass implements Runnable {public voidrun() {
System.out.println("MyThread.run()");
}
}
實作 Callable 接口通過 FutureTask 包裝器來建立 Thread 線程有的時候，我們可能需要讓一步執行的線程在執行完成以
後，提供一個傳回值給到目前的主線程，主線程需要依賴這個值進行後續的邏輯處理，那麼這個時候，就需要用到
帶傳回值的線程了。Java 中提供了這樣的實作方式
public class CallableDemo implements Callable{public static voidmain(String[] args) throws ExecutionException, InterruptedException {
ExecutorService executorService= Executors.newFixedThreadPool(1);
CallableDemo callableDemo= newCallableDemo();
Future future =executorService.submit(callableDemo);
System.out.println(future.get());
executorService.shutdown();
}
@OverridepublicString call() throws Exception {int a = 1;int b = 2;
System.out.println(a +b);return "執行結果:" + (a +b);
}
}
多線程的實際應用場景
其實大家在工作中應該很少有場景能夠應用多線程了，因為基于業務開發來說，很多使用異步的場景我們都通過分布式消息隊列來做了。但并不是說多線程就不會被用到，
你們如果有看一些架構的源碼，會發現線程的使用無處不在之前我應用得比較多的場景是在做檔案跑批，每天會有一些比如收益檔案、對賬檔案，我們會有一個定時任務去拿
到資料然後通過線程去處理
Java 并發程式設計的基礎
基本應用搞清楚以後，我們再來基于Java線程的基礎切入，來逐漸去深入挖掘線程的整體模型。
線程的生命周期
Java 線程既然能夠建立，那麼也勢必會被銷毀，是以線程是存在生命周期的，那麼我們接下來從線程的生命周期開始去了解線程。
線程一共有 6 種狀态(NEW、RUNNABLE、BLOCKED、WAITING、TIME_WAITING、TERMINATED)
NEW：初始狀态，線程被建構，但是還沒有調用 start 方法
RUNNABLED：運作狀态，JAVA 線程把作業系統中的就緒和運作兩種狀态統一稱為“運作中”
BLOCKED：阻塞狀态，表示線程進入等待狀态,也就是線程因為某種原因放棄了 CPU 使用權，阻塞也分為幾種情況
➢ 等待阻塞：運作的線程執行 wait 方法，jvm 會把目前線程放入到等待隊列
➢ 同步阻塞：運作的線程在擷取對象的同步鎖時，若該同步鎖被其他線程鎖占用了，那麼 jvm 會把目前的線程放入到鎖池中
➢ 其他阻塞：運作的線程執行 Thread.sleep 或者 t.join 方法，或者發出了 I/O 請求時，JVM 會把目前線程設定為阻塞狀态，當 sleep 結束、join 線程終止、io 處理完畢則線程恢複
TIME_WAITING：逾時等待狀态，逾時以後自動傳回
TERMINATED：終止狀态，表示目前線程執行完畢
線程狀态圖：
示範線程的狀态如下：
import java.util.concurrent.TimeUnit;public classThreadStatus {public static voidmain(String[] args) {//TIME_WAITING
new Thread(() ->{while (true) {try{
TimeUnit.SECONDS.sleep(5);
System.out.println(Thread.currentThread().getName()+"--TimeUnit.SECONDS.sleep(5)");
}catch(InterruptedException e) {
e.printStackTrace();
}
}
},"timewaiting").start();//WAITING，線程在 ThreadStatus 類鎖上通過 wait 進行等待
new Thread(() ->{while (true) {
synchronized (ThreadStatus.class) {try{
ThreadStatus.class.wait();
System.out.println(Thread.currentThread().getName()+"--ThreadStatus.class.wait()");
}catch(InterruptedException e) {
e.printStackTrace();
}
}
}
},"Waiting").start();//線程在 ThreadStatus 加鎖後，不會釋放鎖
new Thread(new BlockedDemo(), "BlockDemo- 01").start();new Thread(new BlockedDemo(), "BlockDemo- 02").start();
}static classBlockedDemo extends Thread {public voidrun() {
synchronized (BlockedDemo.class) {while (true) {try{
TimeUnit.SECONDS.sleep(3);
System.out.println(Thread.currentThread().getName()+"--TimeUnit.SECONDS.sleep(3)");
}catch(InterruptedException e) {
e.printStackTrace();
}
}
}
}
}
}
運作結果：
D:\Java\jdk1.8.0_91\bin\java.exe "-javaagent:D:\IntelliJ IDEA 2018.2.4\lib\idea_rt.jar=52529:D:\IntelliJ IDEA 2018.2.4\bin" -Dfile.encoding=UTF-8 -classpath "D:\Java\jdk1.8.0_91\jre\lib\charsets.jar;D:\Java\jdk1.8.0_91\jre\lib\deploy.jar;D:\Java\jdk1.8.0_91\jre\lib\ext\access-bridge-32.jar;D:\Java\jdk1.8.0_91\jre\lib\ext\cldrdata.jar;D:\Java\jdk1.8.0_91\jre\lib\ext\dnsns.jar;D:\Java\jdk1.8.0_91\jre\lib\ext\jaccess.jar;D:\Java\jdk1.8.0_91\jre\lib\ext\jfxrt.jar;D:\Java\jdk1.8.0_91\jre\lib\ext\localedata.jar;D:\Java\jdk1.8.0_91\jre\lib\ext\nashorn.jar;D:\Java\jdk1.8.0_91\jre\lib\ext\sunec.jar;D:\Java\jdk1.8.0_91\jre\lib\ext\sunjce_provider.jar;D:\Java\jdk1.8.0_91\jre\lib\ext\sunmscapi.jar;D:\Java\jdk1.8.0_91\jre\lib\ext\sunpkcs11.jar;D:\Java\jdk1.8.0_91\jre\lib\ext\zipfs.jar;D:\Java\jdk1.8.0_91\jre\lib\javaws.jar;D:\Java\jdk1.8.0_91\jre\lib\jce.jar;D:\Java\jdk1.8.0_91\jre\lib\jfr.jar;D:\Java\jdk1.8.0_91\jre\lib\jfxswt.jar;D:\Java\jdk1.8.0_91\jre\lib\jsse.jar;D:\Java\jdk1.8.0_91\jre\lib\management-agent.jar;D:\Java\jdk1.8.0_91\jre\lib\plugin.jar;D:\Java\jdk1.8.0_91\jre\lib\resources.jar;D:\Java\jdk1.8.0_91\jre\lib\rt.jar;D:\IntelliJ IDEA Projects\springbootRabbitmq\target\classes;D:\DevlopeConfig\mavenRepository\org\springframework\boot\spring-boot-starter-web\2.0.0.RELEASE\spring-boot-starter-web-2.0.0.RELEASE.jar;D:\DevlopeConfig\mavenRepository\org\springframework\boot\spring-boot-starter\2.0.0.RELEASE\spring-boot-starter-2.0.0.RELEASE.jar;D:\DevlopeConfig\mavenRepository\org\springframework\boot\spring-boot-starter-logging\2.0.0.RELEASE\spring-boot-starter-logging-2.0.0.RELEASE.jar;D:\DevlopeConfig\mavenRepository\ch\qos\logback\logback-classic\1.2.3\logback-classic-1.2.3.jar;D:\DevlopeConfig\mavenRepository\ch\qos\logback\logback-core\1.2.3\logback-core-1.2.3.jar;D:\DevlopeConfig\mavenRepository\org\apache\logging\log4j\log4j-to-slf4j\2.10.0\log4j-to-slf4j-2.10.0.jar;D:\DevlopeConfig\mavenRepository\org\apache\logging\log4j\log4j-api\2.10.0\log4j-api-2.10.0.jar;D:\DevlopeConfig\mavenRepository\org\slf4j\jul-to-slf4j\1.7.25\jul-to-slf4j-1.7.25.jar;D:\DevlopeConfig\mavenRepository\javax\annotation\javax.annotation-api\1.3.2\javax.annotation-api-1.3.2.jar;D:\DevlopeConfig\mavenRepository\org\yaml\snakeyaml\1.19\snakeyaml-1.19.jar;D:\DevlopeConfig\mavenRepository\org\springframework\boot\spring-boot-starter-json\2.0.0.RELEASE\spring-boot-starter-json-2.0.0.RELEASE.jar;D:\DevlopeConfig\mavenRepository\com\fasterxml\jackson\core\jackson-databind\2.9.4\jackson-databind-2.9.4.jar;D:\DevlopeConfig\mavenRepository\com\fasterxml\jackson\core\jackson-annotations\2.9.0\jackson-annotations-2.9.0.jar;D:\DevlopeConfig\mavenRepository\com\fasterxml\jackson\core\jackson-core\2.9.4\jackson-core-2.9.4.jar;D:\DevlopeConfig\mavenRepository\com\fasterxml\jackson\datatype\jackson-datatype-jdk8\2.9.4\jackson-datatype-jdk8-2.9.4.jar;D:\DevlopeConfig\mavenRepository\com\fasterxml\jackson\datatype\jackson-datatype-jsr310\2.9.4\jackson-datatype-jsr310-2.9.4.jar;D:\DevlopeConfig\mavenRepository\com\fasterxml\jackson\module\jackson-module-parameter-names\2.9.4\jackson-module-parameter-names-2.9.4.jar;D:\DevlopeConfig\mavenRepository\org\springframework\boot\spring-boot-starter-tomcat\2.0.0.RELEASE\spring-boot-starter-tomcat-2.0.0.RELEASE.jar;D:\DevlopeConfig\mavenRepository\org\apache\tomcat\embed\tomcat-embed-core\8.5.28\tomcat-embed-core-8.5.28.jar;D:\DevlopeConfig\mavenRepository\org\apache\tomcat\embed\tomcat-embed-el\8.5.28\tomcat-embed-el-8.5.28.jar;D:\DevlopeConfig\mavenRepository\org\apache\tomcat\embed\tomcat-embed-websocket\8.5.28\tomcat-embed-websocket-8.5.28.jar;D:\DevlopeConfig\mavenRepository\org\hibernate\validator\hibernate-validator\6.0.7.Final\hibernate-validator-6.0.7.Final.jar;D:\DevlopeConfig\mavenRepository\javax\validation\validation-api\2.0.1.Final\validation-api-2.0.1.Final.jar;D:\DevlopeConfig\mavenRepository\org\jboss\logging\jboss-logging\3.3.2.Final\jboss-logging-3.3.2.Final.jar;D:\DevlopeConfig\mavenRepository\com\fasterxml\classmate\1.3.4\classmate-1.3.4.jar;D:\DevlopeConfig\mavenRepository\org\springframework\spring-web\5.0.4.RELEASE\spring-web-5.0.4.RELEASE.jar;D:\DevlopeConfig\mavenRepository\org\springframework\spring-beans\5.0.4.RELEASE\spring-beans-5.0.4.RELEASE.jar;D:\DevlopeConfig\mavenRepository\org\springframework\spring-webmvc\5.0.4.RELEASE\spring-webmvc-5.0.4.RELEASE.jar;D:\DevlopeConfig\mavenRepository\org\springframework\spring-aop\5.0.4.RELEASE\spring-aop-5.0.4.RELEASE.jar;D:\DevlopeConfig\mavenRepository\org\springframework\spring-context\5.0.4.RELEASE\spring-context-5.0.4.RELEASE.jar;D:\DevlopeConfig\mavenRepository\org\springframework\spring-expression\5.0.4.RELEASE\spring-expression-5.0.4.RELEASE.jar;D:\DevlopeConfig\mavenRepository\org\slf4j\slf4j-api\1.7.25\slf4j-api-1.7.25.jar;D:\DevlopeConfig\mavenRepository\org\springframework\spring-core\5.0.4.RELEASE\spring-core-5.0.4.RELEASE.jar;D:\DevlopeConfig\mavenRepository\org\springframework\spring-jcl\5.0.4.RELEASE\spring-jcl-5.0.4.RELEASE.jar;D:\DevlopeConfig\mavenRepository\org\springframework\boot\spring-boot-devtools\2.0.0.RELEASE\spring-boot-devtools-2.0.0.RELEASE.jar;D:\DevlopeConfig\mavenRepository\org\springframework\boot\spring-boot\2.0.0.RELEASE\spring-boot-2.0.0.RELEASE.jar;D:\DevlopeConfig\mavenRepository\org\springframework\boot\spring-boot-autoconfigure\2.0.0.RELEASE\spring-boot-autoconfigure-2.0.0.RELEASE.jar;D:\DevlopeConfig\mavenRepository\org\projectlombok\lombok\1.16.20\lombok-1.16.20.jar;D:\DevlopeConfig\mavenRepository\org\springframework\boot\spring-boot-starter-data-jpa\2.0.0.RELEASE\spring-boot-starter-data-jpa-2.0.0.RELEASE.jar;D:\DevlopeConfig\mavenRepository\org\springframework\boot\spring-boot-starter-aop\2.0.0.RELEASE\spring-boot-starter-aop-2.0.0.RELEASE.jar;D:\DevlopeConfig\mavenRepository\org\aspectj\aspectjweaver\1.8.13\aspectjweaver-1.8.13.jar;D:\DevlopeConfig\mavenRepository\org\springframework\boot\spring-boot-starter-jdbc\2.0.0.RELEASE\spring-boot-starter-jdbc-2.0.0.RELEASE.jar;D:\DevlopeConfig\mavenRepository\com\zaxxer\HikariCP\2.7.8\HikariCP-2.7.8.jar;D:\DevlopeConfig\mavenRepository\org\springframework\spring-jdbc\5.0.4.RELEASE\spring-jdbc-5.0.4.RELEASE.jar;D:\DevlopeConfig\mavenRepository\org\hibernate\hibernate-core\5.2.14.Final\hibernate-core-5.2.14.Final.jar;D:\DevlopeConfig\mavenRepository\org\hibernate\javax\persistence\hibernate-jpa-2.1-api\1.0.0.Final\hibernate-jpa-2.1-api-1.0.0.Final.jar;D:\DevlopeConfig\mavenRepository\org\javassist\javassist\3.22.0-GA\javassist-3.22.0-GA.jar;D:\DevlopeConfig\mavenRepository\antlr\antlr\2.7.7\antlr-2.7.7.jar;D:\DevlopeConfig\mavenRepository\org\jboss\jandex\2.0.3.Final\jandex-2.0.3.Final.jar;D:\DevlopeConfig\mavenRepository\dom4j\dom4j\1.6.1\dom4j-1.6.1.jar;D:\DevlopeConfig\mavenRepository\org\hibernate\common\hibernate-commons-annotations\5.0.1.Final\hibernate-commons-annotations-5.0.1.Final.jar;D:\DevlopeConfig\mavenRepository\javax\transaction\javax.transaction-api\1.2\javax.transaction-api-1.2.jar;D:\DevlopeConfig\mavenRepository\org\springframework\data\spring-data-jpa\2.0.5.RELEASE\spring-data-jpa-2.0.5.RELEASE.jar;D:\DevlopeConfig\mavenRepository\org\springframework\data\spring-data-commons\2.0.5.RELEASE\spring-data-commons-2.0.5.RELEASE.jar;D:\DevlopeConfig\mavenRepository\org\springframework\spring-orm\5.0.4.RELEASE\spring-orm-5.0.4.RELEASE.jar;D:\DevlopeConfig\mavenRepository\org\springframework\spring-tx\5.0.4.RELEASE\spring-tx-5.0.4.RELEASE.jar;D:\DevlopeConfig\mavenRepository\org\springframework\spring-aspects\5.0.4.RELEASE\spring-aspects-5.0.4.RELEASE.jar;D:\DevlopeConfig\mavenRepository\mysql\mysql-connector-java\5.1.38\mysql-connector-java-5.1.38.jar;D:\DevlopeConfig\mavenRepository\org\springframework\boot\spring-boot-starter-amqp\2.0.0.RELEASE\spring-boot-starter-amqp-2.0.0.RELEASE.jar;D:\DevlopeConfig\mavenRepository\org\springframework\spring-messaging\5.0.4.RELEASE\spring-messaging-5.0.4.RELEASE.jar;D:\DevlopeConfig\mavenRepository\org\springframework\amqp\spring-rabbit\2.0.2.RELEASE\spring-rabbit-2.0.2.RELEASE.jar;D:\DevlopeConfig\mavenRepository\org\springframework\amqp\spring-amqp\2.0.2.RELEASE\spring-amqp-2.0.2.RELEASE.jar;D:\DevlopeConfig\mavenRepository\com\rabbitmq\amqp-client\5.1.2\amqp-client-5.1.2.jar;D:\DevlopeConfig\mavenRepository\com\rabbitmq\http-client\1.3.1.RELEASE\http-client-1.3.1.RELEASE.jar;D:\DevlopeConfig\mavenRepository\org\apache\httpcomponents\httpclient\4.5.5\httpclient-4.5.5.jar;D:\DevlopeConfig\mavenRepository\org\apache\httpcomponents\httpcore\4.4.9\httpcore-4.4.9.jar;D:\DevlopeConfig\mavenRepository\commons-codec\commons-codec\1.11\commons-codec-1.11.jar;D:\DevlopeConfig\mavenRepository\org\springframework\retry\spring-retry\1.2.2.RELEASE\spring-retry-1.2.2.RELEASE.jar"com.lf.Configuration.ThreadStatus
BlockDemo- 01--TimeUnit.SECONDS.sleep(3)
timewaiting--TimeUnit.SECONDS.sleep(5)
BlockDemo- 01--TimeUnit.SECONDS.sleep(3)
BlockDemo- 01--TimeUnit.SECONDS.sleep(3)
timewaiting--TimeUnit.SECONDS.sleep(5)
BlockDemo- 01--TimeUnit.SECONDS.sleep(3)
BlockDemo- 01--TimeUnit.SECONDS.sleep(3)
timewaiting--TimeUnit.SECONDS.sleep(5)
BlockDemo- 01--TimeUnit.SECONDS.sleep(3)
timewaiting--TimeUnit.SECONDS.sleep(5)
BlockDemo- 01--TimeUnit.SECONDS.sleep(3)
BlockDemo- 01--TimeUnit.SECONDS.sleep(3)
timewaiting--TimeUnit.SECONDS.sleep(5)
BlockDemo- 01--TimeUnit.SECONDS.sleep(3)
啟動一個線程前，最好為這個線程設定線程名稱，因為這樣在使用 jstack 分析程式或者進行問題排查時，就會給開發人員提供一些提示顯示線程的狀态
➢ 運作該示例，打開終端或者指令提示符，鍵入“jps”，
JDK1.5 提供的一個顯示目前所有 java 程序 pid 的指令)
➢ 根據上一步驟獲得的 pid，繼續輸入 jstack pid(jstack是 java 虛拟機自帶的一種堆棧跟蹤工具。jstack 用于列印出給定的 java 程序 ID 或 core file 或遠端調試服務的 Java 堆棧資訊)
通過上面的分析，我們了解到了線程的生命周期，現在在整個生命周期中并不是固定的處于某個狀态，而是随着代碼的執行在不同的狀态之間進行切換
内容如下：
4384ThreadStatus8084
4360Jps
bash-3.1$ jstack 4384
2020-05-06 23:20:41Full thread dump Java HotSpot(TM) Client VM (25.91-b14 mixed mode):"DestroyJavaVM" #15 prio=5 os_prio=0 tid=0x0342b400 nid=0x30e0 waiting on condition [0x00000000]
java.lang.Thread.State: RUNNABLE"BlockDemo- 02" #14 prio=5 os_prio=0 tid=0x161d1c00 nid=0x3164 waiting for monitor entry [0x167cf000]
java.lang.Thread.State: BLOCKED (onobjectmonitor)
at com.lf.Configuration.ThreadStatus$BlockedDemo.run(ThreadStatus.java:41)- waiting to lock <0x05661d28> (a java.lang.Class forcom.lf.Configuration.ThreadStatus$BlockedDemo)
at java.lang.Thread.run(Thread.java:745)"BlockDemo- 01" #12 prio=5 os_prio=0 tid=0x161cf000 nid=0x24c8 waiting on condition [0x1673f000]
java.lang.Thread.State: TIMED_WAITING (sleeping)
at java.lang.Thread.sleep(Native Method)
at java.lang.Thread.sleep(Thread.java:340)
at java.util.concurrent.TimeUnit.sleep(TimeUnit.java:386)
at com.lf.Configuration.ThreadStatus$BlockedDemo.run(ThreadStatus.java:41)- locked <0x05661d28> (a java.lang.Class forcom.lf.Configuration.ThreadStatus$BlockedDemo)
at java.lang.Thread.run(Thread.java:745)"Waiting" #10 prio=5 os_prio=0 tid=0x161cdc00 nid=0x1bd8 in Object.wait() [0x166af000]
java.lang.Thread.State: WAITING (onobjectmonitor)
at java.lang.Object.wait(Native Method)- waiting on <0x05ad2000> (a java.lang.Class forcom.lf.Configuration.ThreadStatus)
at java.lang.Object.wait(Object.java:502)
at com.lf.Configuration.ThreadStatus.lambda$main$1(ThreadStatus.java:23)- locked <0x05ad2000> (a java.lang.Class forcom.lf.Configuration.ThreadStatus)
at com.lf.Configuration.ThreadStatus$$Lambda$2/30452001.run(Unknown Source)
at java.lang.Thread.run(Thread.java:745)"timewaiting" #9 prio=5 os_prio=0 tid=0x161cd000 nid=0x1298 waiting on condition [0x1661f000]
java.lang.Thread.State: TIMED_WAITING (sleeping)
at java.lang.Thread.sleep(Native Method)
at java.lang.Thread.sleep(Thread.java:340)
at java.util.concurrent.TimeUnit.sleep(TimeUnit.java:386)
at com.lf.Configuration.ThreadStatus.lambda$main$0(ThreadStatus.java:11)
at com.lf.Configuration.ThreadStatus$$Lambda$1/8844017.run(Unknown Source)
at java.lang.Thread.run(Thread.java:745)"Service Thread" #8 daemon prio=9 os_prio=0 tid=0x160a3c00 nid=0x1e24 runnable [0x00000000]
java.lang.Thread.State: RUNNABLE"C1 CompilerThread0" #7 daemon prio=9 os_prio=2 tid=0x16063c00 nid=0x1a64 waiting on condition [0x00000000]
java.lang.Thread.State: RUNNABLE"Monitor Ctrl-Break" #6 daemon prio=5 os_prio=0 tid=0x160a6800 nid=0xc58 runnable [0x163df000]
java.lang.Thread.State: RUNNABLE
at java.net.SocketInputStream.socketRead0(Native Method)
at java.net.SocketInputStream.socketRead(SocketInputStream.java:116)
at java.net.SocketInputStream.read(SocketInputStream.java:170)
at java.net.SocketInputStream.read(SocketInputStream.java:141)
at sun.nio.cs.StreamDecoder.readBytes(StreamDecoder.java:284)
at sun.nio.cs.StreamDecoder.implRead(StreamDecoder.java:326)
at sun.nio.cs.StreamDecoder.read(StreamDecoder.java:178)- locked <0x05aee288>(a java.io.InputStreamReader)
at java.io.InputStreamReader.read(InputStreamReader.java:184)
at java.io.BufferedReader.fill(BufferedReader.java:161)
at java.io.BufferedReader.readLine(BufferedReader.java:324)- locked <0x05aee288>(a java.io.InputStreamReader)
at java.io.BufferedReader.readLine(BufferedReader.java:389)
at com.intellij.rt.execution.application.AppMainV2$1.run(AppMainV2.java:64)"Attach Listener" #5 daemon prio=5 os_prio=2 tid=0x15a91000 nid=0x1230 waiting on condition [0x00000000]
java.lang.Thread.State: RUNNABLE"Signal Dispatcher" #4 daemon prio=9 os_prio=2 tid=0x15a8f800 nid=0x3150 runnable [0x00000000]
java.lang.Thread.State: RUNNABLE"Finalizer" #3 daemon prio=8 os_prio=1 tid=0x15a7d000 nid=0x11f8 in Object.wait() [0x15dcf000]
java.lang.Thread.State: WAITING (onobjectmonitor)
at java.lang.Object.wait(Native Method)- waiting on <0x05aee758> (a java.lang.ref.ReferenceQueue$Lock)
at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:143)- locked <0x05aee758> (a java.lang.ref.ReferenceQueue$Lock)
at java.lang.ref.ReferenceQueue.remove(ReferenceQueue.java:164)
at java.lang.ref.Finalizer$FinalizerThread.run(Finalizer.java:209)"Reference Handler" #2 daemon prio=10 os_prio=2 tid=0x15a67400 nid=0x1b8c in Object.wait() [0x15d3f000]
java.lang.Thread.State: WAITING (onobjectmonitor)
at java.lang.Object.wait(Native Method)- waiting on <0x05aee8f8> (a java.lang.ref.Reference$Lock)
at java.lang.Object.wait(Object.java:502)
at java.lang.ref.Reference.tryHandlePending(Reference.java:191)- locked <0x05aee8f8> (a java.lang.ref.Reference$Lock)
at java.lang.ref.Reference$ReferenceHandler.run(Reference.java:153)"VM Thread" os_prio=2 tid=0x15a61400 nid=0x1ec4runnable"VM Periodic Task Thread" os_prio=2 tid=0x1619ac00 nid=0xfe0waiting on condition
JNIglobal references: 232bash-3.1$
線程的啟動
前面我們通過一些案例示範了線程的啟動，也就是調用start()方法去啟動一個線程，當 run 方法中的代碼執行完畢以後，線程的生命周期也将終止。
調用 start 方法的語義是目前線程告訴 JVM，啟動調用 start 方法的線程。
線程的啟動原理
很多同學最早學習線程的時候會比較疑惑，啟動一個線程為什麼是調用 start 方法，而不是 run 方法，這做一個簡單的分析，先簡單看一下 start 方法的定義
我們看到調用 start 方法實際上是調用一個 native 方法start0()來啟動一個線程，首先 start0()這個方法是在Thread 的靜态塊中來注冊的，代碼如下
更深入的。。。囧
線程的終止
線程的啟動過程大家都非常熟悉，但是如何終止一個線程呢？ 這是面試過程中針對 3 年左右的人喜歡問到的一個題目。
線程的終止，并不是簡單的調用 stop 指令去。雖然 api 仍然可以調用，但是和其他的線程控制方法如 suspend、resume 一樣都是過期了的不建議使用，
就拿 stop 來說，stop 方法在結束一個線程時并不會保證線程的資源正常釋放，是以會導緻程式可能出現一些不确定的狀态。
要優雅的去中斷一個線程，線上程中提供了一個 interrupt方法
interrupt 方法
當其他線程通過調用目前線程的 interrupt 方法，表示向目前線程打個招呼，告訴他可以中斷線程的執行了，至于什
麼時候中斷，取決于目前線程自己。線程通過檢查資深是否被中斷來進行相應，可以通過isInterrupted()來判斷是否被中斷。
通過下面這個例子，來實作了線程終止的邏輯
public classInterruptDemo {private static inti;public static voidmain(String[] args) throws InterruptedException {
Thread thread= new Thread(() ->{while (!Thread.currentThread().isInterrupted()) { //預設情況下isInterrupted 傳回 false、通過 thread.interrupt 變成了 true
i++;
}
System.out.println("Num:" +i);
},"interruptDemo");
thread.start();
TimeUnit.SECONDS.sleep(1);
thread.interrupt();//加和不加的效果
}
}
加了，線程運作一會會被打斷，并輸出Num值
不加，線程會一直運作
Thread.interrupted
上面的案例中，通過 interrupt，設定了一個辨別告訴線程可 以 終 止 了 ， 線 程 中 還 提 供 了 靜 态 方 法Thread.interrupted()對設定中斷辨別的線程複位。比如在
上面的案例中，外面的線程調用 thread.interrupt 來設定中斷辨別，而線上程裡面，又通過 Thread.interrupted 把線程的辨別又進行了複位
public classInterruptDemo2 {private static inti;public static voidmain(String[] args) throws InterruptedException {
Thread thread= new Thread(() ->{while (true) {if(Thread.currentThread().isInterrupted()) {
System.out.println("before:" +Thread.currentThread().isInterrupted());
Thread.interrupted();//對線程進行複位，由 true 變成 false
System.out.println("after:" +Thread.currentThread().isInterrupted());
}
}
},"interruptDemo");
thread.start();
TimeUnit.SECONDS.sleep(1);
thread.interrupt();
}
}
運作結果：
before:trueafter:false
其他的線程複位
除了通過 Thread.interrupted 方法對線程中斷辨別進行複 位 以 外 ， 還 有 一 種 被 動 複 位 的 場 景 ， 就 是 對 抛 出 InterruptedException 異 常 的 方 法 ，
在 InterruptedException 抛出之前，JVM 會先把線程的中斷 辨別位清除，然後才會抛出 InterruptedException，這個時 候如果調用 isInterrupted 方法，
将會傳回 false 分别通過下面兩個 demo 來示範複位的效果
demo1public static voidmain(String[] args) throws InterruptedException {
Thread thread= new Thread(() ->{while (!Thread.currentThread().isInterrupted()) {
i++;
}
System.out.println("Num:" +i);
},"interruptDemo");
thread.start();
TimeUnit.SECONDS.sleep(1);
thread.interrupt();
System.out.println(thread.isInterrupted());
}
輸出：
true
Num:36375203
private static inti;
demo2public static voidmain(String[] args) throws InterruptedException {
Thread thread= new Thread(() ->{while (!Thread.currentThread().isInterrupted()) {try{
TimeUnit.SECONDS.sleep(1);
}catch(InterruptedException e) {
e.printStackTrace();
}
}
System.out.println("Num:" +i);
},"interruptDemo");
thread.start();
TimeUnit.SECONDS.sleep(1);
thread.interrupt();
System.out.println(thread.isInterrupted());
}
輸出：
false
java.lang.InterruptedException: sleep interrupted
at java.lang.Thread.sleep(Native Method)
at java.lang.Thread.sleep(Thread.java:340)
at java.util.concurrent.TimeUnit.sleep(TimeUnit.java:386)
at com.lf.Configuration.InterruptDemoCompare.lambda$main$0(InterruptDemoCompare.java:12)
at java.lang.Thread.run(Thread.java:745)
為什麼要複位
Thread.interrupted()是屬于目前線程的，是目前線程對外界中斷信号的一個響應，表示自己已經得到了中斷信号，
但不會立刻中斷自己，具體什麼時候中斷由自己決定，讓外界知道在自身中斷前，他的中斷狀态仍然是 false，這就是複位的原因。
線程的終止原理
我們來看一下 thread.interrupt()方法做了什麼事情
這個方法裡面，調用了 interrupt0()，這個方法在前面分析start 方法的時候見過，是一個 native 方法，這裡就不再重
複貼代碼了，同樣，我們找到 jvm.cpp 檔案，找到JVM_Interrupt 的定義
這個方法比較簡單，直接調用了 Thread::interrupt(thr)這個方法，這個方法的定義在 Thread.cpp 檔案中，代碼如下
Thread::interrupt 方法調用了 os::interrupt 方法，這個是調用平台的 interrupt 方法，這個方法的實作是在 os_*.cpp
檔案中，其中星号代表的是不同平台，因為 jvm 是跨平台的，是以對于不同的操作平台，線程的排程方式都是不一樣的。
我們以 os_linux.cpp 檔案為例
set_interrupted(true)實際上就是調用 osThread.hpp 中的
set_interrupted()方法，在 osThread 中定義了一個成員屬
性 volatile jint _interrupted;
通過上面的代碼分析可以知道，thread.interrupt()方法實際就是設定一個 interrupted 狀态辨別為 true、并且通過
ParkEvent 的 unpark 方法來喚醒線程。
1. 對于 synchronized 阻塞的線程，被喚醒以後會繼續嘗試擷取鎖，如果失敗仍然可能被 park
2. 在調用 ParkEvent 的 park 方法之前，會先判斷線程的中斷狀态，如果為 true，會清除目前線程的中斷辨別
3. Object.wait 、 Thread.sleep 、 Thread.join 會 抛 出InterruptedException
這裡給大家普及一個知識點，為什麼 Object.wait、Thread.sleep和Thread.join
會 抛 出InterruptedException? 你會發現這幾個方法有一個共同點，都是屬于阻塞的方法
而阻塞方法的釋放會取決于一些外部的事件，但是阻塞方法可能因為等不到外部的觸發事件而導緻無法終止，是以它允許一個線程請求自己來停止它正在做的事情。
當一個方法抛出 InterruptedException 時，它是在告訴調用者如果執行該方法的線程被中斷，它會嘗試停止正在做的事情
并且通過抛出 InterruptedException 表示提前傳回。是以，這個異常的意思是表示一個阻塞被其他線程中斷了。
然 後 ， 由 于 線 程 調 用 了 interrupt() 中 斷 方 法 ， 那 麼Object.wait、Thread.sleep 等被阻塞的線程被喚醒以後會
通過 is_interrupted 方法判斷中斷辨別的狀态變化，如果發現中斷辨別為 true，則先清除中斷辨別，然後抛出InterruptedException
需要注意的是，InterruptedException 異常的抛出并不意味着線程必須終止，而是提醒目前線程有中斷的操作發生，
至于接下來怎麼處理取決于線程本身，比如
1. 直接捕獲異常不做任何處理
2. 将異常往外抛出
3. 停止目前線程，并列印異常資訊
為 了 讓 大 家 能 夠 更 好 的 理 解 上 面 這 段 話 ， 我 們 以Thread.sleep 為例直接從 jdk 的源碼中找到中斷辨別的清
除以及異常抛出的方法代碼找 到 is_interrupted() 方法， linux 平 台 中 的 實 現 在
os_linux.cpp 檔案中，代碼如下
找到 Thread.sleep 這個操作在 jdk 中的源碼展現，怎麼找?相信如果前面大家有認真看的話，應該能很快找到，
代碼在 jvm.cpp 檔案中
注意上面加了中文注釋的地方的代碼，先判斷is_interrupted 的 狀 态 ， 然 後 抛 出 一 個
InterruptedException 異常。到此為止，我們就已經分析清楚了中斷的整個流程。
之前看 zookeeper 源碼的時候看到一個比較有意思的異步責任鍊模式
package com.lf.Configuration;
import lombok.Getter;
import lombok.Setter;
import lombok.ToString;
@ToStringpublic classRequest {
@Getter
@SetterprivateString name;
}
package com.lf.Configuration;public interfaceRequestProcessor {voidprocessRequest(Request request);
}
package com.lf.Configuration;
import java.util.concurrent.LinkedBlockingQueue;public classSaveProcessor extends Thread implements RequestProcessor {
LinkedBlockingQueue requests = new LinkedBlockingQueue();
@Overridepublic voidrun() {while (true) {try{//隊列為空，阻塞等待。//隊列不為空，從隊首擷取并移除一個元素，如果消費後還有元素在隊列中，繼續喚醒下一個消費線程進行元素移除。//如果放之前隊列是滿元素的情況，移除完後要喚醒生産線程進行添加元素
System.out.println("SaveProcessor: begin");
Request request= requests.take();//System.out.println("save request info:" +request);
}catch(InterruptedException e) {
e.printStackTrace();
}
}
}//處理請求
public voidprocessRequest(Request request) {
requests.add(request);
}
}
package com.lf.Configuration;
import java.util.concurrent.LinkedBlockingQueue;public classPrintProcessor extends Thread implements RequestProcessor {
LinkedBlockingQueue requests = new LinkedBlockingQueue<>();privatefinal RequestProcessor nextProcessor;publicPrintProcessor(RequestProcessor nextProcessor) {this.nextProcessor =nextProcessor;
}
@Overridepublic voidrun() {while (true) {try{//隊列為空，阻塞等待。//隊列不為空，從隊首擷取并移除一個元素，如果消費後還有元素在隊列中，繼續喚醒下一個消費線程進行元素移除。//如果放之前隊列是滿元素的情況，移除完後要喚醒生産線程進行添加元素
System.out.println("PrintProcessor: begin");
Request request=requests.take();
System.out.println("print data:" +request.getName());
nextProcessor.processRequest(request);
}catch(InterruptedException e) {
e.printStackTrace();
}
}
}//處理請求
public voidprocessRequest(Request request) {
requests.add(request);
}
}
package com.lf.Configuration;public classMain {
PrintProcessor printProcessor;protectedMain() {
SaveProcessor saveProcessor= newSaveProcessor();
saveProcessor.start();
printProcessor= newPrintProcessor(saveProcessor);
printProcessor.start();
}private voiddoTest(Request request) {
printProcessor.processRequest(request);
}public static voidmain(String[] args) {
Request request= newRequest();
request.setName("lf");newMain().doTest(request);
}
}
運作結果：
SaveProcessor: begin
PrintProcessor: begin
print data:lf
PrintProcessor: begin
save request info:Request(name=lf)
SaveProcessor: begin