java多線程從入門到精通看這篇就夠了
一.認識線程及線程的創(chuàng)建
1.線程的概念
線程和進程的區(qū)別:
進程是系統(tǒng)分配資源的最小單位,線程是系統(tǒng)調(diào)度的最小單位。
一個進程內(nèi)的線程之間是可以共享資源的。
每個進程至少有一個線程存在,即主線程。
注:
每個進程至少有一個線程存在,即主線程(系統(tǒng)級別的,C語言的主線程)
java級別的主線程(自己寫的入口函數(shù)main方法(可以沒有這個線程)
對java進程來說,至少有一個非守護線程還沒終止,進程就不會結(jié)束
2.線程的特性
在后面線程的安全性會詳細介紹
1.原子性:即一個操作或者多個操作 要么全部執(zhí)行并且執(zhí)行的過程不會被任何因素打斷,要么就都不執(zhí)行。
2.可見性:當多個線程訪問同一個變量時,一個線程修改了這個變量的值,其他線程能夠立即看得到修改的值。
3.有序性:程序執(zhí)行的順序按照代碼的先后順序執(zhí)行。
3.線程的創(chuàng)建方式
<1>繼承Thread類
class MyThread extends Thread{ @Override public void run() { System.out.println("繼承Thread類創(chuàng)建線程"); } } public static void main(String[] args) { //1.繼承Thread類創(chuàng)建線程 MyThread t=new MyThread(); t.start(); }
<2>實現(xiàn)Runnable接口
1.將MyRunnable對象作為任務傳入Thread中
class MyRunnable implements Runnable{ @Override public void run() { System.out.println("繼承Runnable接口,創(chuàng)建描述任務對象,實現(xiàn)多線程"); } } public static void main(String[] args) { //2.實現(xiàn)Runnable接口 Thread t1=new Thread(new MyRunnable()); t1.start(); }
2.使用匿名內(nèi)部類實現(xiàn)
Thread t2=new Thread(new Runnable() { @Override public void run() { System.out.println("使用Runnable接口,創(chuàng)建匿名內(nèi)部類實現(xiàn)"); } }); t2.start();
<3>實現(xiàn)Callable接口
實現(xiàn)Callable重現(xiàn)call方法,允許拋出異常,允許帶有返回值,返回數(shù)據(jù)類型為接口上的泛型
class MyCallable implements Callable<String> { //允許拋出異常,允許帶有返回值,返回數(shù)據(jù)類型為接口上的泛型 @Override public String call() throws Exception { System.out.println("實現(xiàn)了Callable接口"); return "這不是一個線程類,而是一個任務類"; } } public static void main(String[] args) throws ExecutionException, InterruptedException { //方法三:實現(xiàn)Callable接口,是一個任務類 //FutureTask底層也實現(xiàn)了Runnable接口 FutureTask<String> task=new FutureTask<>(new MyCallable()); new Thread(task).start(); System.out.println(task.get()); }
二.線程的常用方法
1.構(gòu)造方法和屬性的獲取方法
構(gòu)造方法:
屬性的獲取方法:
2.常用方法
<1>run()和start()
start();方法:啟動線程
run();方法:覆寫 run 方法是提供給線程要做的事情的指令清單
start()和run()的區(qū)別:見代碼
public class Thread_Run_VS_Start { public static void main(String[] args) { new Thread(new Runnable() { @Override public void run() { while (true){ } } }).run(); /** * main線程直接調(diào)用Thread對象的run方法會直接在main線程 * 運行Thread對象的run()方法---->傳入的runnable對象.run() * 結(jié)果,main線程直接運行while(true) * * start()是啟動一個線程,調(diào)用新線程的while(true)方法 * 對比通過start()調(diào)用的結(jié)果區(qū)別 */ new Thread(new Runnable() { @Override public void run() { while (true){ } } }).start(); } }
<2>interrupt()方法
通過interrupt()方法,通知線程中的中斷標志位,由false變?yōu)閠rue,但是線程什么時候中斷,需要線程自己的代碼實現(xiàn)
通過線程中的中斷標志位實現(xiàn),比起自己手動設(shè)置中斷標志位,可以避免線程處于阻塞狀態(tài)下,無法中斷的情況
對interrupt,isInterrupt,interrupted的理解:
實例方法:
(1)interrupt:置線程的中斷狀態(tài)
如果調(diào)用該方法的線程處于阻塞狀態(tài)(休眠等),會拋出InterruptedException異常并且會重置Thread.interrupted;返回當前標志位,并重置(2)isInterrupt:線程是否中斷,返回boolean 靜態(tài)方法:(3)interrupted:返回線程的上次的中斷狀態(tài),并清除中斷狀態(tài)
public class Interrupt { public static void main(String[] args) throws InterruptedException { Thread t=new Thread(new Runnable() { @Override public void run() { //...執(zhí)行任務,執(zhí)行時間可能比較長 //運行到這里,在t的構(gòu)造方法中不能引用t使用Thread.currentThread()方法,獲取當前代碼行所在線程的引用 for (int i = 0; i <10000&&!Thread.currentThread().isInterrupted() ; i++) { System.out.println(i); //模擬中斷線程 try { Thread.sleep(1000); //通過標志位自行實現(xiàn),無法解決線程阻塞導致無法中斷 //Thread,sleep(100000) } catch (InterruptedException e) { e.printStackTrace(); } } } }); t.start();//線程啟動,中斷標志位=false System.out.println("t start"); //模擬,t執(zhí)行了5秒,進程沒有結(jié)束,要中斷,停止t線程 Thread.sleep(5000); //未設(shè)置時,isInterrupt為false //如果t線程處于阻塞狀態(tài)(休眠等),會拋出InterruptedException異常 //并且會重置isInterrupt中斷標志位位false t.interrupt();//告訴t線程,要中斷(設(shè)置t線程的中斷標志位為true),由t的代碼自行決定是否要中斷 //isInterrupt設(shè)置為true //t.isInterrupted(); Interrupted是線程中的標志位 System.out.println("t stop"); //注:Thread.interrupted(); 返回當前線程的中斷標志位,然后重置中斷標志位 } }
<3>join方法
注意: join方法是實例方法
等待一個線程執(zhí)行完畢,才執(zhí)行下一個線程(調(diào)用該方法的線程等待)
無參
:t.join:當前線程無條件等待,直到t線程運行完畢
有參
:t.join(1000)等待1秒,或者t線程結(jié)束,哪個條件滿足,當前線程繼續(xù)往下執(zhí)行
//join方法:實例方法: // 1.無參:t.join:當前線程無條件等待,直到t線程運行完畢 // 2.有參:t.join(1000)等待1秒,或者t線程結(jié)束,哪個條件滿足,當前線程繼續(xù)往下執(zhí)行 public class Join { public static void main(String[] args) throws InterruptedException { Thread t=new Thread(new Runnable() { @Override public void run() { System.out.println("1"); } }); t.start(); t.join();//當前線程main線程無條件等待,直到t線程執(zhí)行完畢,當前線程再往后執(zhí)行 // t.join(1000);當前線程等到1秒,或者等t線程執(zhí)行完畢 System.out.println("ok"); } }
<4>獲取當前線程的引用currentThread();方法
靜態(tài)方法:
public class ThreadDemo { public static void main(String[] args) { Thread thread = Thread.currentThread(); System.out.println(thread.getName()); } }
<5>休眠當前線程sleep();方法
讓線程等待一定時間后,繼續(xù)運行
Thread.sleep(1000);
<6>線程讓步y(tǒng)ield();方法
讓yield();所在代碼行的線程讓步,當其他線程先執(zhí)行
public class Yield { public static void main(String[] args) { for(int i=0;i<20;i++){ final int n=i; Thread t=new Thread(new Runnable() { @Override public void run() { System.out.println(n); } }); t.start(); } //判斷:如果活躍的線程數(shù)量大于1,main線程讓步 while (Thread.activeCount()>1){//記錄活躍線程的數(shù)量 Thread.yield(); }//注意:要用debug方式,因為run方式,idea后臺還會啟動一個線程 //實現(xiàn)ok在1到二十之后打印 System.out.println("ok"); } }
三.線程的生命周期和狀態(tài)轉(zhuǎn)換
Java 語言中線程共有六種狀態(tài),分別是:
NEW
(初始化狀態(tài))
RUNNABLE
(可運行 / 運行狀態(tài))
BLOCKED
(阻塞狀態(tài))
WAITING
(無時限等待)
TIMED_WAITING
(有時限等待)
TERMINATED
(終止狀態(tài))
生命周期和狀態(tài)轉(zhuǎn)換圖:
常見的API導致的狀態(tài)轉(zhuǎn)換:
1.線程的阻塞:
Thread.sleep(long);當前線程休眠
t.join/t.join(long);t線程加入當前線程,當前線程等待阻塞
synchronized:競爭對象鎖失敗的線程,進入阻塞態(tài)
2.線程的啟動:
start() ----->注意:run()只是任務的定義,start()才是啟動
3. 線程的中斷:interrupt讓某個線程中斷,不是直接停止線程,而是一個“建議”,是否中斷,由線程代碼自己決定
四.線程間的通信
wait(0方法
:線程等待 notify();方法
:隨機喚醒一個線程 notifyAll():方法
:喚醒所有等待的線程 注意:這三個方法都需要被Synchronized包裹x
線程間通信的案例:
有三個線程,每個線程只能打印A,B或C
要求:同時執(zhí)行三個線程,按ABC順序打印,依次打印十次
ABC換行 ABC換行。。。。
public class SequencePrintHomeWork { //有三個線程,每個線程只能打印A,B或C //要求:同時執(zhí)行三個線程,按ABC順序打印,依次打印十次 //ABC換行 ABC換行。。。。 //考察知識點:代碼設(shè)計,多線程通信 public static void main(String[] args) { Thread a = new Thread(new Task("A")); Thread b = new Thread(new Task("B")); Thread c = new Thread(new Task("C")); c.start(); b.start(); a.start(); } private static class Task implements Runnable{ private String content; //順序打印的內(nèi)容:可以循環(huán)打印 private static String[] ARR = {"A", "B", "C"}; private static int INDEX;//從數(shù)組哪個索引打印 public Task(String content) { this.content = content; } @Override public void run() { try { for(int i=0; i<10; i++){ synchronized (ARR){//三個線程使用同一把鎖 //從數(shù)組索引位置打印,如果當前線程要打印的內(nèi)容不一致,釋放對象鎖等待 while(!content.equals(ARR[INDEX])){ ARR.wait(); } //如果數(shù)組要打印的內(nèi)容和當前線程要打印的一致, // 就打印,并把數(shù)組索引切換到一個位置,通知其他線程 System.out.print(content); if(INDEX==ARR.length-1){ System.out.println(); } INDEX = (INDEX+1)%ARR.length; ARR.notifyAll(); } } } catch (InterruptedException e) { e.printStackTrace(); } } } }
補充: wait()和sleep()的區(qū)別:
wait
之前需要請求鎖,而wait執(zhí)行時會先釋放鎖,等被喚醒時再重新請求鎖。這個鎖是 wait 對象上的 monitor lock
sleep
是無視鎖的存在的,即之前請求的鎖不會釋放,沒有鎖也不會請求。
wait
是 Object 的方法
sleep
是 Thread 的靜態(tài)方法
五.多線程的安全及解決
1.原子性
對原子性的理解: 我們把一段代碼想象成一個房間,每個線程就是要進入這個房間的人。如果沒有任何機制保證,A進入房間之后,還沒有出來;B 是不是也可以進入房間,打斷 A 在房間里的隱私。這個就是不具備原子性的。
注意: 一條 java 語句不一定是原子的,也不一定只是一條指令
例如:
如果一個線程正在對一個變量操作,中途其他線程插入進來了,如果這個操作被打斷了,結(jié)果就可能是錯誤的。
2.可見性
為了提高效率,JVM在執(zhí)行過程中,會盡可能的將數(shù)據(jù)在工作內(nèi)存中執(zhí)行,但這樣會造成一個問題,共享變量在多線程之間不能及時看到改變,這個就是可見性問題。
可見性
:系統(tǒng)調(diào)度CPU執(zhí)行線程內(nèi),某個方法,產(chǎn)生CPU視角的主存,工作內(nèi)存
主存
:線程共享
工作內(nèi)存
:線程私有內(nèi)存+CPU高速緩存/寄存器
對主存中共享數(shù)據(jù)的操作,存在主存到工作內(nèi)存<====>從主存讀取,工作內(nèi)存修改,寫回主存(拷貝)
3.代碼的順序性
代碼的重排序:
一段代碼:
1.去前臺取下 U 盤
2. 去教室寫 10 分鐘作業(yè)
3. 去前臺取下快遞
如果是在單線程情況下,JVM、CPU指令集會對其進行優(yōu)化,比如,按 1->3->2的方式執(zhí)行,也是沒問題,可以少跑一次前臺。這種叫做指令重排序
代碼重排序會給多線程帶來什么問題:
剛才那個例子中,單線程情況是沒問題的,優(yōu)化是正確的,但在多線程場景下就有問題了,什么問題呢??赡芸爝f是在你寫作業(yè)的10分鐘內(nèi)被另一個線程放過來的,或者被人變過了,如果指令重排序了,代碼就會是錯誤的。
4.線程不安全問題的解決
<1>synchronized 關(guān)鍵字
這里會在下面鎖體系中詳細說
<2>volatile 關(guān)鍵字
volatile 關(guān)鍵字的作用:
(1)保證可見性
(2)禁止指令重排序,建立內(nèi)存屏障——單例模式說明
(3)不保證原子性
常見的使用場景:一般是讀寫分離的操作,提高性能
(1)寫操作不依賴共享變量,賦值是一個常量(依賴共享變量的賦值不是原子性操作)
(2)作用在讀,寫依賴其他手段(加鎖)
一個volatile的簡單例子:
public class Test { private static boolean flag = true; public static void main(String[] args) { //創(chuàng)建一個線程并啟動 new Thread(new Runnable() { int i=0; @Override public void run() { while(flag){ //這個語句底層使用了synchronized,保證了可見性 //System.out.println("============="); i++; } } }).start(); try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } //即使改了,上面的線程flag也不會改,會一直循環(huán) flag = false; } }
六.鎖體系
多線程中鎖的作用:保證線程的同步
1.Synchronized加鎖方式
<1>Synchronized的加鎖方式及語法基礎(chǔ)
如何解決上述原子性例子的問題:
是不是只要給房間加一把鎖,A 進去就把門鎖上,其他人是不是就進不來了。這樣就保證了這段代碼的原子性了。有時也把這個現(xiàn)象叫做同步互斥,表示操作是互相排斥的。
synchronized 關(guān)鍵字:
(1)作用:對一段代碼進行加鎖操作,讓某一段代碼滿足三個特性:原子性,可見性,有序性
(2)原理:多個線程間同步互斥(一段代碼在任意一個時間點,只有一個線程執(zhí)行:加鎖,釋放鎖)
注意: 加鎖/釋放鎖是基于對象來進行加鎖和釋放鎖,不是把代碼鎖了
只有對同一個對象加鎖,才會讓線程產(chǎn)生同步互斥的效果:
那么怎樣才叫對同一個對象加鎖呢?
這里t代表類名,t1,t2是 new了兩個t increment是t中的一個方法(是靜態(tài)還是實例具體看)
synchronized處加鎖,拋出異?;虼a塊結(jié)束釋放鎖
具體過程:
synchronized 多個線程n同步互斥:
(1):一個時間只有一個線程執(zhí)行(同步互斥)
(2):競爭失敗的線程,不停的在阻塞態(tài)和運行態(tài)切換(用戶態(tài)和內(nèi)核態(tài)切換)
(3)同步線程數(shù)量越多,性能越低
一個簡單的小例子:
public class SafeThread { //有一個遍歷COUNT=0;同時啟動20個線程,每個線程循環(huán)1000次,每次循環(huán)把COUNT++ //等待二十個子線程執(zhí)行完畢之后,再main中打印COUNT的值 //(預期)count=20000 private static int COUNT=0; //對當前類對象進行加鎖,線程間同步互斥 // public synchronized static void increment(){ // COUNT++; // } //使用不同的對象加鎖,沒有同步互斥的效果,并發(fā)并行 // public static void increment(){ // synchronized (new SafeThread()){ // COUNT++; // } // } public static void main(String[] args) throws InterruptedException { //盡量同時啟動,不讓new線程操作影響 Class clazz=SafeThread.class; Thread[]threads=new Thread[20]; for (int i = 0; i <20 ; i++) { threads[i]=new Thread(new Runnable() { @Override public void run() { for (int j = 0; j <1000 ; j++) { //給SafeThread對象加一把鎖 synchronized (clazz){ COUNT++; } } } }); } for (int i = 0; i <20 ; i++) { threads[i].start(); } //讓main線程等待20個子線程運行完畢 for (int i = 0; i <20 ; i++) { threads[i].join(); } System.out.println(COUNT); } }
synchronized加鎖的缺點:
a)如果獲取鎖的線程由于要等待IO或其他原因(如調(diào)用sleep方法)被阻塞了,但又沒有釋放鎖,其他線程只能干巴巴地等待,此時會影響程序執(zhí)行效率。
b)只要獲取了synchronized鎖,不管是讀操作還是寫操作,都要上鎖,都會獨占。如果希望多個讀操作可以同時運行,但是一個寫操作運行,無法實現(xiàn)。
<2>Synchronized的原理及實現(xiàn)
1.Monitor機制:
(1)基于monitor對象的監(jiān)視器:使用對象頭的鎖狀態(tài)來加鎖
(2)編譯為字節(jié)碼指令為:1個monitoren+2個monitorexit 多出來的一個monitorexit:如果出現(xiàn)異常,第一個monitorexit無法正確釋放鎖,這個monitorexit進行鎖釋放
例如下列代碼:
public class Test1 { public Test1() { } public static void main(String[] args) { Class var1 = Test1.class; synchronized(Test1.class) { System.out.println("hello"); } } }
反編譯:
(3)monitor存在計數(shù)器實現(xiàn)synchronized的可重入性:進入+1,退出-1;
<3>JVM對Synchronized的優(yōu)化
(1).對鎖的優(yōu)化
Synchronized是基于對象頭的鎖狀態(tài)來實現(xiàn)的,從低到高:(鎖只能升級不能降級)
(1)無鎖
(2)偏向鎖:對同一個對象多次加鎖(重入)
(3)輕量級鎖:基于CAS實現(xiàn),同一個時間點,經(jīng)常只有一個線程競爭鎖
(4)重量級鎖:基于系統(tǒng)的mutex鎖,同一個時間點,經(jīng)常有多個線程競爭
特點:mutex是系統(tǒng)級別的加鎖,線程會由用戶態(tài)切換到內(nèi)核態(tài),切換的成本比較高(一個線程總是競爭失敗,就會不停的在用戶態(tài)和內(nèi)核態(tài)之間切換,比較耗費資源,進一步,如果很多個競爭失敗的線程,性能就會有很大的影響)
(2).鎖粗話
多個synchronized連續(xù)執(zhí)行加鎖,釋放鎖,可以合并為一個
示例:StringBuffer靜態(tài)變量,在一個線程中多次append(靜態(tài)變量屬于方法區(qū),jdk 1.8后是在堆里面,線程共享)
public class Test { private static StringBuffer sb; public static void main(String[] args) { sb.append("1").append("2").append("3"); } }
(3).鎖消除
對不會逃逸到其他線程的變量,執(zhí)行加鎖的操作,可以刪除加鎖
示例:StringBuffer局部變量,在一個線程中多次append(局部變量屬于虛擬機棧,是線程私有的)
public class Test { public static void main(String[] args) { StringBuffer sb=new StringBuffer(); sb.append("1"); sb.append("2"); sb.append("3"); } }
2.常見的鎖策略及CAS
多線程中鎖類型的劃分:
API層面:
synchronized加鎖 Lock加鎖
鎖的類型
:偏向鎖,輕量級鎖,重量級鎖,自旋鎖,獨占鎖,共享鎖,公平鎖,非公平鎖等等
<1>.樂觀鎖和悲觀鎖
樂觀鎖和悲觀鎖的設(shè)計思想(和語言是無關(guān)的,不是java多線程獨有的)
根據(jù)使用常見來闡述:
樂觀鎖
:同一個時間點,經(jīng)常只有一個線程來操作共享變量,適合使用樂觀鎖
悲觀鎖
:同一個時間點,經(jīng)常有多個線程來操作共享變量,適合使用悲觀鎖
樂觀鎖的實現(xiàn)原理:
通過直接操作共享變變量(不會阻塞),通過調(diào)用的api的返回值,來知道操作是成功還是失敗的 java多線程的實現(xiàn):基于CAS的方式實現(xiàn)(Compare and Swap)
令:主存中需要操作的變量為V,線程A的工作內(nèi)存中,讀入A,修改為N
有另一個線程可能對主存中的V進行操作
此時:新的主存中操作的變量令為O,比較線程A中的V和此時主存中的O是否相等,如果相等,說明可以將N寫回主存,如果不相等,任務主存中的變量被B線程操作過,此時A中的N不寫入主存,線程A不做任何事情。
悲觀鎖的實現(xiàn)原理:類似于synchronized加鎖方式
**CAS中可能存在的問題(ABA問題) **
肯主存中原來的V值,被線程B加一,再減一,依然滿足上述線程A可以寫入N的條件
解決辦法:為主存中的變量加上一個版本好,在上訴A線程可寫入的基礎(chǔ)上,再比較一次版本好。即可解決。
CAS在java中是使用unsafe類來完成的,本質(zhì)上是基于CPU提供的對變量原子性線程安全的修改操作
<2>自旋鎖
按照普通加鎖的方式處理,當線程在搶鎖失敗之后會進入阻塞狀態(tài),放棄CPU,需要經(jīng)過很久才能被再次調(diào)度,所以,引入讀寫鎖,當鎖競爭失敗之后,只需要很短時間,鎖就能再次被釋放,此時,讓競爭失敗的線程,進入自旋,不在用戶態(tài)和內(nèi)核態(tài)之間切換。只要沒搶到鎖,就死等。
類似以下代碼:
<1>.無條件的自選:
while(搶鎖(lock)==失敗{}
自旋鎖的缺陷:如果之前的假設(shè)(鎖很快就能被釋放)沒有滿足,那么進入自旋的線程就一直在消耗CPU的資源,長期在做無用功
<2>.有條件的自旋:
如可中斷的自旋:自旋時線程判斷中斷標志位后再執(zhí)行,或者限制自旋的次數(shù),限制自旋的時間
自旋鎖,悲觀樂觀鎖,CAS的總結(jié):
<1>.悲觀鎖是線程先加鎖,之后再修改變量的操作
<2>.樂觀鎖是線程直接嘗試修改變量(不會阻塞)。在java多線程中是基于CAS 實現(xiàn)的。
<3>.CAS
概念:Compare and Swap比較并交換
實現(xiàn)/原理:基于unsafe來實現(xiàn),本質(zhì)上是基于CPU提供的接口保證線程安全修改變量。
使用(V,O,N):V為內(nèi)存地址中存放的實際值,O為預期的值(舊值),N為更新的值(新值)
可能出現(xiàn)的問題:ABA問題(引入版本號解決)
<4>.自旋+CAS
適用的場景:同一個時間點,常常只有一個線程進行操作
不適應的場景:
1.同一個時間點,常常有多個線程進行操作
2.CAS的操作時間時間太長,給了其他線程操作共享變量的機會,那么CAS的成功率會很低,經(jīng)常做無用功
自旋的缺陷:線程一直處于運行態(tài),會很耗費CPU的資源
<3>可重入鎖
允許同一個線程多次獲取同一把鎖
java中只要以Reentrant開頭命名的鎖都是可重入的鎖,現(xiàn)有的jdk提供的lock的實現(xiàn)類和synchronized加鎖,都是可重入鎖例如:
public class Test2 { public static synchronized void t1(){ t2(); } public static synchronized void t2(){ } public static void main(String[] args) { t1(); } }
3.Lock體系
<1>Lock接口
(1)使用Lock鎖實現(xiàn)線程同步
上代碼!
public class AccountRunnable implements Runnable { private Account account = new Account(); //買一把鎖 Lock lock = new ReentrantLock(); //Re-entrant-Lock 可重入鎖 @Override public void run() { //此處省略300句 try{ //上鎖 lock.lock(); //判斷余額是否足夠,夠,取之;不夠,不取之; if(account.getBalance()>=400){ try { Thread.sleep(1); } catch (InterruptedException e) { e.printStackTrace(); } method1(); //取之 account.withDraw(400); //輸出信息 System.out.println(Thread.currentThread().getName()+ "取款成功,現(xiàn)在的余額是"+account.getBalance()); }else{ System.out.println("余額不足,"+Thread.currentThread().getName() +"取款失敗,現(xiàn)在的余額是" +account.getBalance()); } }finally { //解鎖 lock.unlock(); } //此處省略100句 } }
這里要注意:釋放鎖時,要考慮是否出現(xiàn)異常,和上面synchronized加鎖相同,要進行兩次鎖釋放,這里將鎖放在finally代碼塊中
(2)Lock加鎖的四種方式
形象記憶:男生追女生
1.lock()
:一直表白,直到成功
lock()方法是平常使用得最多的一個方法,就是用來獲取鎖。如果鎖已被其他線程獲取,則進行等待。
2.tryLock()
:表白一次,失敗就放棄
tryLock()方法是有返回值的,它表示用來嘗試獲取鎖,如果獲取成功,則返回true,如果獲取失?。存i已被其他線程獲?。?,則返回false,也就說這個方法無論如何都會立即返回。拿不到鎖時不會一直在那等待。
3.tryLock
(long time, TimeUnit unit) 在一定的時間內(nèi)持續(xù)表白,如果時間到了則放棄
tryLock(long time, TimeUnit unit)方法和tryLock()方法是類似的,只不過區(qū)別在于這個方法在拿不到鎖時會等待一定的時間,在時間期限之內(nèi)如果還拿不到鎖,就返回false。如果如果一開始拿到鎖或者在等待期間內(nèi)拿到了鎖,則返回true。
4.lockInterruptibly()
一直表白,當被通知她有男朋友了,才放棄 lockInterruptibly()方法比較特殊,當通過這個方法去獲取鎖時,如果線程正在等待獲取鎖,則這個線程能夠響應中斷,即中斷線程的等待狀態(tài)。
也就使說,當這個線程使用lockInterruptibly()獲取鎖,當被interrupt中斷時,才會停止競爭鎖
<2>AQS簡單認識
AQS: AbstractQuenedSynchronizer抽象的隊列式同步器。是除了java自帶的synchronized關(guān)鍵字之外的鎖機制。這個類在java.util.concurrent.locks包.
AQS的核心思想是: 如果被請求的共享資源空閑,則將當前請求資源的線程設(shè)置為有效的工作線程,并將共享資源設(shè)置為鎖定狀態(tài),如果被請求的共享資源被占用,那么就需要一套線程阻塞等待以及被喚醒時鎖分配的機制,這個機制AQS是用CLH隊列鎖實現(xiàn)的,即將暫時獲取不到鎖的線程加入到隊列中。
AQS的實現(xiàn)方式:
如圖示,AQS維護了一個volatile int state和一個FIFO線程等待隊列,多線程爭用資源被阻塞的時候就會進入這個隊列。state就是共享資源
AQS 定義了兩種資源共享方式:
1.Exclusive:獨占,只有一個線程能執(zhí)行,如ReentrantLock
2.Share:共享,多個線程可以同時執(zhí)行,如Semaphore、CountDownLatch、ReadWriteLock,CyclicBarrier
<3>ReentrantLock
(1)ReentrantLock基本概念
ReentrantLock
,意思是“可重入鎖”。ReentrantLock是唯一實現(xiàn)了Lock接口的非內(nèi)部類,并且ReentrantLock提供了更多的方法。
ReentrantLock鎖
在同一個時間點只能被一個線程鎖持有。
ReentraantLock
是通過一個FIFO的等待隊列來管理獲取該鎖所有線程的。在“公平鎖”的機制下,線程依次排隊獲取鎖;而“非公平鎖”在鎖是可獲取狀態(tài)時,不管自己是不是在隊列的開頭都會獲取鎖。
當單個線程或線程交替執(zhí)行時,他與隊列無關(guān),只會在jdk級別解決,性能高
(2)自己實現(xiàn)一個簡單的ReentrantLock
原理:自旋+park–unpark+CAS
public class Test2 { volatile int status=0; Queue parkQueue;//集合 數(shù)組 list void lock(){ while(!compareAndSet(0,1)){ //這里不能用sleep或yield實現(xiàn) //sleep無法確定睡眠的時間 //yield只能用于兩個線程競爭,當有多個線程之后,t1搶不到鎖,yield會讓出cpu,但是可能下一次cpu還是調(diào)t1 park(); } unlock(); } void unlock(){ lock_notify(); } void park(){ //將當期線程加入到等待隊列 parkQueue.add(currentThread); //將當期線程釋放cpu 阻塞 睡眠 releaseCpu(); } void lock_notify(){ //status=0 //得到要喚醒的線程頭部線程 Thread t=parkQueue.header(); //喚醒等待線程 unpark(t); } }
(3)ReentrantLock部分源碼分析
ReentrantLock鎖分為公平鎖和非公平鎖(創(chuàng)建不加參數(shù)時默認非公平鎖)
ReentrantLock提供了兩個構(gòu)造器:
//非公平鎖 public ReentrantLock() { sync = new NonfairSync(); } //公平鎖 public ReentrantLock(boolean fair) { sync = fair ? new FairSync() : new NonfairSync(); }
ReentrantLock的lock方式:
非公平鎖:
調(diào)用lock方法:
final void lock() { if (compareAndSetState(0, 1))//首先用一個CAS操作,判斷state是否是0(表示當前鎖未被占用) setExclusiveOwnerThread(Thread.currentThread());//設(shè)置當前占有鎖的線程為該線程 else acquire(1); }
首先用一個CAS操作,判斷state是否是0(表示當前鎖未被占用),如果是0則把它置為1,并且設(shè)置當前線程為該鎖的獨占線程,表示獲取鎖成功。當多個線程同時嘗試占用同一個鎖時,CAS操作只能保證一個線程操作成功,剩下的只能乖乖的去排隊。
“非公平”即體現(xiàn)在這里,如果占用鎖的線程剛釋放鎖,state置為0,而排隊等待鎖的線程還未喚醒時,新來的線程就直接搶占了該鎖,那么就“插隊”了。
下面說說acquire的過程
public final void acquire(int arg) { //首先看看自己要不要排隊,如果不用排隊,獲取鎖,要排隊,加入AQS隊列 if (!tryAcquire(arg) && acquireQueued(addWaiter(Node.EXCLUSIVE), arg)) selfInterrupt(); }
(1)嘗試去獲取鎖(看看自己要不要排隊)
非公平鎖tryAcquire的流程是:檢查state字段,若為0,表示鎖未被占用,那么嘗試占用,若不為0,檢查當前鎖是否被自己占用,若被自己占用,則更新state字段,表示重入鎖的次數(shù)。如果以上兩點都沒有成功,則獲取鎖失敗,返回false。
tryAcquire(arg) final boolean nonfairTryAcquire(int acquires) { //獲取當前線程 final Thread current = Thread.currentThread(); //獲取state變量值 int c = getState(); if (c == 0) { //沒有線程占用鎖 if (compareAndSetState(0, acquires)) { //占用鎖成功,設(shè)置獨占線程為當前線程 setExclusiveOwnerThread(current); return true; } } else if (current == getExclusiveOwnerThread()) { //當前線程已經(jīng)占用該鎖 重入鎖 int nextc = c + acquires; if (nextc < 0) // overflow throw new Error("Maximum lock count exceeded"); // 更新state值為新的重入次數(shù) setState(nextc); return true; } //獲取鎖失敗 return false; }
(2)入隊根據(jù)java運算符短路,如果不需要排隊,方法直接返回,如果需要排隊,進入addWaiter方法
公平鎖:
公平鎖和非公平鎖不同之處在于,公平鎖在獲取鎖的時候,不會先去檢查state狀態(tài),而是直接執(zhí)行aqcuire(1)
<4>ReadWriteLock鎖
ReadWriteLock也是一個接口,在它里面只定義了兩個方法:
public interface ReadWriteLock { Lock readLock(); Lock writeLock(); }
一個用來獲取讀鎖,一個用來獲取寫鎖。也就是說將文件的讀寫操作分開,分成2個鎖來分配給線程,從而使得多個線程可以同時進行讀操作。
ReadWriteLock
是一個接口,ReentrantReadWriteLock是它的實現(xiàn)類,該類中包括兩個內(nèi)部類ReadLock和WriteLock,這兩個內(nèi)部類實現(xiàn)了Lock接口。
認識ReadWriteLock鎖
public class TestLock { public static void main(String[] args) { //默認也是非公平鎖 也是可重入鎖 ReadWriteLock rwl = new ReentrantReadWriteLock(); //多次返回的都是同一把讀鎖 同一把寫鎖 Lock readLock = rwl.readLock(); Lock readLock2 = rwl.readLock(); Lock writeLock = rwl.writeLock(); readLock.lock(); readLock.unlock(); System.out.println(readLock==readLock2); } }
注意:從結(jié)果中看到,從一個ReadWriteLock中多次獲取的ReadLock、WriteLock是同一把讀鎖,同一把寫鎖。
4.Lock鎖和同步鎖(synchronized)的區(qū)別
5.死鎖
先上代碼:
package threadadvanced.lesson1; class Pen { private String pen = "筆" ; public String getPen() { return pen; } } class Book { private String book = "本" ; public String getBook() { return book; } } public class DeadLock { private static Pen pen = new Pen() ; private static Book book = new Book() ; public static void main(String[] args) { new DeadLock().deadLock(); } public void deadLock() { Thread thread1 = new Thread(new Runnable() { // 筆線程 @Override public void run() { synchronized (pen) { try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println(Thread.currentThread()+" :我有筆,我就不給你"); synchronized (book) { System.out.println(Thread.currentThread()+" :把你的本給我!"); } } } },"Pen") ; Thread thread2 = new Thread(new Runnable() { // 本子線程 @Override public void run() { synchronized (book) { System.out.println(Thread.currentThread()+" :我有本子,我就不給你!"); synchronized (pen) { System.out.println(Thread.currentThread()+" :把你的筆給我!"); } } } },"Book") ; thread1.start(); thread2.start(); } }
出現(xiàn)死鎖:
jconsole檢查死鎖:
1.死鎖出現(xiàn)的原因:
至少兩個線程,互相持有對方需要的資源沒有釋放,再次申請對方以及持有的資源
2.出現(xiàn)死鎖的后果:
線程互相阻塞等待地方的資源,會一直處于阻塞等待的狀態(tài)
3.如何檢測死鎖:
使用jdk工具:jconsole(查看線程)---->jstack
4.解決死鎖的方法:
(1)資源一次性分配(破壞請求與保持條件)
(2)在滿足一定條件的時候,主動釋放資源
(3)資源的有序分配:系統(tǒng)為每一類資源賦予一個編號,每個線程按照編號遞請求資源,釋放則相反
七.多線程案例
1.生產(chǎn)者消費者問題
示例:
面包店
10個生產(chǎn)者,每個每次生產(chǎn)3個
20個消費者,每個每次消費一個
進階版需求
面包師傅每個最多生產(chǎn)30次,面包店每天生產(chǎn)10303=900個面包
消費者也不是一直消費。把900個面包消費完結(jié)束
隱藏信息:面包店每天生產(chǎn)面包的最大數(shù)量為900個
消費者把900個面包消費完結(jié)束
代碼示例:
/** * 面包店 * 10個生產(chǎn)者,每個每次生產(chǎn)3個 * 20個消費者,每個每次消費一個 * * 進階版需求 * 面包師傅每個最多生產(chǎn)30次,面包店每天生產(chǎn)10*30*3=900個面包 * 消費者也不是一直消費。把900個面包消費完結(jié)束 * * 隱藏信息:面包店每天生產(chǎn)面包的最大數(shù)量為900個 * 消費者把900個面包消費完結(jié)束 */ public class AdvancedBreadShop { //面包店庫存數(shù) private static int COUNT; //面包店生產(chǎn)面包的總數(shù),不會消費的 private static int PRODUCE_NUMBER; public static class Consumer implements Runnable{ private String name; public Consumer(String name) { this.name = name; } @Override public void run() { try { while (true){ synchronized (AdvancedBreadShop.class){ if(PRODUCE_NUMBER==900&&COUNT==0){ System.out.println("今天面包已經(jīng)賣完了"); break; }else { if(COUNT==0){ AdvancedBreadShop.class.wait(); }else { System.out.printf("%s消費了一個面包\n",this.name); COUNT--; AdvancedBreadShop.class.notifyAll(); Thread.sleep(100); } } } Thread.sleep(100); } } catch (InterruptedException e) { e.printStackTrace(); } } } private static class Producer implements Runnable{ private String name; public Producer(String name) { this.name = name; } @Override public void run() { try { //生產(chǎn)者生產(chǎn)30次,結(jié)束循環(huán) for(int i=0;i<=30;i++) { synchronized (AdvancedBreadShop.class){ if(i==30){ System.out.println("今天面包生產(chǎn)完了"); break; }else { if(COUNT>97){ AdvancedBreadShop.class.wait(); }else { COUNT=COUNT+3; PRODUCE_NUMBER=PRODUCE_NUMBER+3; System.out.printf("%s生產(chǎn)了三個面包\n",this.name); AdvancedBreadShop.class.notifyAll(); Thread.sleep(100); } } } Thread.sleep(100); } } catch (InterruptedException e) { e.printStackTrace(); } } } public static void main(String[] args) { Thread[] Consumers=new Thread[20]; Thread[] Producers=new Thread[10]; for (int i = 0; i <20 ; i++) { Consumers[i]=new Thread(new Consumer(String.valueOf(i))); } for (int i = 0; i <10 ; i++) { Producers[i]=new Thread(new Producer(String.valueOf(i))); } for (int i = 0; i <20 ; i++) { Consumers[i].start(); } for (int i = 0; i <10 ; i++) { Producers[i].start(); } } }
2.單例模式
基于單例模式下的懶漢模式(雙重校驗鎖實現(xiàn))(多線程版,二次判斷,效率高)代碼示例:
public class Singleton { //volatile關(guān)鍵字修飾,保證的可見性和代碼的順序性 private static volatile Singleton instance = null; private Singleton() { } public static Singleton getInstance() { //判斷instance是否為空,競爭鎖的條件 if (instance == null) { //保證線程安全,為Singleton.class加鎖 synchronized (Singleton.class) { //再次判斷instance是否為空,防止多個線程進入第一個if后 //對synchronized鎖競爭失敗進入阻塞狀態(tài)后,再次進入運行態(tài)時 //new了多個Singleton,不符合單例模式 //保證線程安全 if (instance == null) { instance = new Singleton(); } } } return instance; } }
3.阻塞式隊列
生產(chǎn)者消費者模式就是通過一個容器來解決生產(chǎn)者和消費者的強耦合問題。生產(chǎn)者和消費者彼此之間不直接通訊,而通過阻塞隊列來進行通訊,所以生產(chǎn)者生產(chǎn)完數(shù)據(jù)之后不用等待消費者處理,直接扔給阻塞隊列,消費者不找生產(chǎn)者要數(shù)據(jù),而是直接從阻塞隊列里取,阻塞隊列就相當于一個緩沖區(qū),平衡了生產(chǎn)者和消費者的處理能力。這個阻塞隊列就是用來給生產(chǎn)者和消費者解耦的。
阻塞式隊列代碼實現(xiàn):
/** * 實現(xiàn)阻塞隊列 * 1.線程安全問題:在多線程情況下,put,take不具有原子性,4個屬性,不具有可見性 * 2.put操作:如果存滿了,需要阻塞等待。take操作:如果是空,阻塞等待 * @param <T> */ public class MyBlockingQueue <T>{ //使用數(shù)組實現(xiàn)循環(huán)隊列 private Object[] queue; //存放元素的索引 private int putIndex ; //取元素的索引 private int takeIndex; //當前存放元素的數(shù)量 private int size; public MyBlockingQueue(int len){ queue=new Object[len]; } //存放元素,需要考慮: //1.putIndex超過數(shù)組長度 //2.size達到數(shù)組最大長度 public synchronized void put(T e) throws InterruptedException { //不滿足執(zhí)行條件時,一直阻塞等待 //當阻塞等待都被喚醒并再次競爭成功對象鎖,回復往下執(zhí)行時,條件可能被其他線程修改 while (size==queue.length){ this.wait(); } //存放到數(shù)組中放元素的索引位置 queue[putIndex]=e; putIndex=(putIndex+1)%queue.length; size++; notifyAll(); } //取元素 public synchronized T take() throws InterruptedException { while (size==0){ this.wait(); } T t= (T) queue[takeIndex]; queue[takeIndex]=null; takeIndex=(takeIndex+1)%queue.length; size--; notifyAll(); return t; } public int size(){ return size; } public static void main(String[] args) { MyBlockingQueue<Integer>queue=new MyBlockingQueue<>(10); //多線程的調(diào)試方式:1.寫打印語句 2.jconsole for (int i = 0; i <3 ; i++) { new Thread(new Runnable() { @Override public void run() { try { for (int j = 0; j <100 ; j++) { queue.put(j); } } catch (InterruptedException e) { e.printStackTrace(); } } }).start(); } for (int i = 0; i <3 ; i++) { new Thread(new Runnable() { @Override public void run() { try { while (true){ int t= queue.take(); System.out.println(Thread.currentThread().getName()+":"+t); } } catch (InterruptedException e) { e.printStackTrace(); } } }).start(); } } }
4.線程池
線程池最大的好處就是減少每次啟動、銷毀線程的損耗
import java.util.concurrent.*; public class ThreadPoolExecutorTest { public static void main(String[] args) { //以快遞公司,快遞員,快遞業(yè)務為模型 ThreadPoolExecutor pool=new ThreadPoolExecutor( 5,//核心線程數(shù)---->正式員工數(shù) 10,//最大線程數(shù)-->正式員工+臨時員工 60,//臨時工的最大等待時間 TimeUnit.SECONDS,//idle線程的空閑時間-->臨時工最大的存活時間,超過就解雇 new LinkedBlockingQueue<>(),//阻塞隊列,任務存放的地方--->快遞倉庫 new ThreadFactory() { @Override public Thread newThread(Runnable r) { return new Thread(new Runnable() { @Override public void run() { //r對象是線程池內(nèi)部封裝過的工作任務類(Worker),會一直循環(huán)等待的方式從阻塞隊列中拿取任務并執(zhí)行 //所以不能調(diào)用r.run();方法 System.out.println(Thread.currentThread().getName()+"開始執(zhí)行了"); } }); } },//創(chuàng)建線程的工廠類 線程池創(chuàng)建線程時,調(diào)用該工廠類的方法創(chuàng)建線程(滿足該工廠創(chuàng)建線程的要求) //---->對應招聘員工的標準 /** * 拒絕策略:達到最大線程數(shù)且阻塞隊列已滿,采取拒絕策略 * AbortPolicy:直接拋出RejectedExecutionException(不提供handler時的默認策略) * CallerRunsPolicy:誰(某個線程)交給我(線程池)的任務,我拒絕執(zhí)行,由誰自己去執(zhí)行 * DiscardPolicy:交給我的任務直接丟棄掉 * DiscardOldestPolicy:阻塞隊列中最舊的任務丟棄 */ new ThreadPoolExecutor.AbortPolicy()//拒絕策略-->達到最大線程數(shù),且阻塞隊列已滿,采取的拒絕策略 );//線程池創(chuàng)建以后,只要有任務們就會自動執(zhí)行 for (int i = 0; i <20 ; i++) { //線程池執(zhí)行任務:execute方法,submit方法--->提交執(zhí)行一個任務 //區(qū)別:返回值不同 pool.execute(new Runnable() { @Override public void run() { try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } } }); } //線程池有4個快捷的創(chuàng)建方式(實際工作不使用,作為面試了解) //實際工作需要使用ThreadPoolExecutor,構(gòu)造參數(shù)是我們自己指定,比較靈活 ExecutorService pool2=Executors.newSingleThreadExecutor();//創(chuàng)建單線程池 ExecutorService pool3=Executors.newCachedThreadPool();//緩存的線程池 ExecutorService pool5=Executors.newFixedThreadPool(4);//固定大小線程池 ScheduledExecutorService pool4=Executors.newScheduledThreadPool(4);//計劃任務線程池 //兩秒中之后執(zhí)行這個任務 pool4.schedule(new Runnable() { @Override public void run() { System.out.println("hello"); } }, 2, TimeUnit.SECONDS); //一直執(zhí)行任務 pool4.scheduleAtFixedRate(new Runnable() { @Override public void run() { System.out.println("hello"); } }, 2, 1,TimeUnit.SECONDS);//比如一個腦子,兩秒后開始叫我,然后每隔一秒叫我一次 } }
八.總結(jié)
(1)代碼塊鎖是一個防止數(shù)據(jù)發(fā)生錯誤的一個重要手段;
(2)對象的統(tǒng)一性是非常重要的,這要想到對象的傳入問題,要操作的對象只能new一次,其他的操作都是對這個傳入的對象進行的,才能保證數(shù)據(jù)一致性,完整性和正確性。
到此這篇關(guān)于一篇文章讓java多線程從入門到精通的文章就介紹到這了,更多相關(guān)java多線程從入門到精通內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
Java使用多線程批次查詢大量數(shù)據(jù)(Callable返回數(shù)據(jù))方式
今天給大家分享Java使用多線程批次查詢大量數(shù)據(jù)(Callable返回數(shù)據(jù))方式,多線程有好幾種方式,今天說的方式比較好,實現(xiàn)Callable<> 這種方式能返回查詢的數(shù)據(jù),加上Future異步獲取方式,查詢效率大大加快,感興趣的朋友一起看看吧2023-11-11thymeleaf中前后端數(shù)據(jù)交互方法匯總
這篇文章主要介紹了thymeleaf中前后端數(shù)據(jù)交互小結(jié),本文通過示例代碼給大家介紹的非常詳細,對大家的學習或工作具有一定的參考借鑒價值,需要的朋友參考下吧2022-07-07Mybatis高級映射、動態(tài)SQL及獲得自增主鍵的解析
MyBatis 本是apache的一個開源項目iBatis, 2010年這個項目由apache software foundation 遷移到了google code,并且改名為MyBatis。這篇文章主要介紹了Mybatis高級映射、動態(tài)SQL及獲得自增主鍵的相關(guān)資料,需要的朋友可以參考下2016-11-11SpringBoot中@Pattern注解對時間格式校驗方式
這篇文章主要介紹了SpringBoot中@Pattern注解對時間格式校驗方式,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教2021-09-09JAVA三種攔截方式詳解(原生過濾器Filter、springMVC攔截器、aop切面)
在Java開發(fā)中方法攔截是一種常見的技術(shù),可以用于在方法執(zhí)行前后添加額外的邏輯或修改方法的行為,這篇文章主要給大家介紹了關(guān)于JAVA三種攔截方式的相關(guān)資料,文中介紹的方式分別是原生過濾器Filter、springMVC攔截器、aop切面,需要的朋友可以參考下2024-05-05