線程基礎(chǔ)
1. 線程的生命周期
1.1 新建狀態(tài):
- 使用 new 關(guān)鍵字和 Thread 類或其子類建立一個線程對象后,該線程對象就處于新建狀態(tài)。它保持這個狀態(tài)直到程序 start() 這個線程。
1.2 就緒狀態(tài):
- 當(dāng)線程對象調(diào)用了start()方法之后,該線程就進(jìn)入就緒狀態(tài)。就緒狀態(tài)的線程處于就緒隊列中,要等待JVM里線程調(diào)度器的調(diào)度。
1.3 運(yùn)行狀態(tài):
- 如果就緒狀態(tài)的線程獲取 CPU 資源,就可以執(zhí)行 run(),此時線程便處于運(yùn)行狀態(tài)。處于運(yùn)行狀態(tài)的線程最為復(fù)雜,它可以變?yōu)樽枞麪顟B(tài)、就緒狀態(tài)和死亡狀態(tài)。
1.4 阻塞狀態(tài):
-
如果一個線程執(zhí)行了sleep(睡眠)、suspend(掛起)等方法,失去所占用資源之后,該線程就從運(yùn)行狀態(tài)進(jìn)入阻塞狀態(tài)。在睡眠時間已到或獲得設(shè)備資源后可以重新進(jìn)入就緒狀態(tài)。可以分為三種:
- 等待阻塞:運(yùn)行狀態(tài)中的線程執(zhí)行 wait() 方法,使線程進(jìn)入到等待阻塞狀態(tài)。
- 同步阻塞:線程在獲取 synchronized 同步鎖失敗(因為同步鎖被其他線程占用)。
- 其他阻塞:通過調(diào)用線程的 sleep() 或 join() 發(fā)出了 I/O 請求時,線程就會進(jìn)入到阻塞狀態(tài)。當(dāng)sleep() 狀態(tài)超時,join() 等待線程終止或超時,或者 I/O 處理完畢,線程重新轉(zhuǎn)入就緒狀態(tài)。
1.5 死亡狀態(tài):
- 一個運(yùn)行狀態(tài)的線程完成任務(wù)或者其他終止條件發(fā)生時,該線程就切換到終止?fàn)顟B(tài)。
2. 線程的優(yōu)先級和守護(hù)線程
2.1 線程的優(yōu)先級
- 每一個 Java 線程都有一個優(yōu)先級,這樣有助于操作系統(tǒng)確定線程的調(diào)度順序。
-
Java 線程的優(yōu)先級是一個整數(shù),其取值范圍是
1 (Thread.MIN_PRIORITY ) - 10 (Thread.MAX_PRIORITY )
。 -
默認(rèn)情況下,每一個線程都會分配一個優(yōu)先級
NORM_PRIORITY(5)
。
2.2 守護(hù)線程
- Java中有兩種線程:用戶線程和守護(hù)線程。可以通過isDeamon()方法來區(qū)別它們:如果返回false,則說明該線程是“用戶線程”;否則就是“守護(hù)線程”。
- 用戶線程一般用戶執(zhí)行用戶級任務(wù),而守護(hù)線程也就是“后臺線程”,一般用來執(zhí)行后臺任務(wù)。
- 需要注意的是:JVM在“用戶線程”都結(jié)束后會退出。
3. 創(chuàng)建線程
3.1 通過實(shí)現(xiàn) Runnable 接口
-
步驟:
- 創(chuàng)建類實(shí)現(xiàn) Runnable 接口
- 實(shí)現(xiàn) run() 方法,線程實(shí)際運(yùn)行的方法
- 實(shí)現(xiàn) start() 方法,里面實(shí)例化線程對象(new Thread(this, threadName)),調(diào)用線程對象的 start() 方法
-
代碼實(shí)現(xiàn)
package com.ljw.thread; public class RunnableDemo { public static void main(String[] args) { // 測試 RunnableDemo R = new RunnableDemo(); RunnableThread R1 = R.new RunnableThread("thread1"); R1.start(); RunnableThread R2 = R.new RunnableThread("thread2"); R2.start(); } class RunnableThread implements Runnable{ private String threadName; private Thread t; public RunnableThread(String name) { // TODO Auto-generated constructor stub threadName = name; System.out.println("創(chuàng)建線程 "+threadName); } @Override public void run() { System.out.println("正在運(yùn)行線程:"+threadName); try { for(int i=10;i>0;i--) { System.out.println("線程:"+threadName+" 正在打印:"+i); Thread.sleep(50); } }catch(Exception e) { e.printStackTrace(); } System.out.println("線程:"+threadName+" 正在退出......"); } public void start() { System.out.println("開始線程 "+threadName); if(t == null) { t = new Thread(this, threadName); t.start(); } } } }
3.2 通過繼承 Thread 類本身
-
步驟:
- 創(chuàng)建類繼承 Thread 類
- 下面與用Runnable接口一樣
3.3 通過 Callable 和 Future 創(chuàng)建線程
-
步驟:
- 創(chuàng)建 Callable 接口的實(shí)現(xiàn)類,并實(shí)現(xiàn) call() 方法,該 call() 方法將作為線程執(zhí)行體,并且有返回值。
- 創(chuàng)建 Callable 實(shí)現(xiàn)類的實(shí)例,使用 FutureTask 類來包裝 Callable 對象,該 FutureTask 對象封裝了該 Callable 對象的 call() 方法的返回值。
- 使用 FutureTask 對象作為 Thread 對象的 target 創(chuàng)建并啟動新線程。
- 調(diào)用 FutureTask 對象的 get() 方法來獲得子線程執(zhí)行結(jié)束后的返回值。
-
Callable接口與Runnable接口的區(qū)別:
- Callable中call方法可以有返回值,而Runnable中的run方法沒有返回值
-
代碼實(shí)現(xiàn)
package com.ljw.thread; import java.util.concurrent.Callable; import java.util.concurrent.FutureTask; public class CallableThreadTest implements Callable { public static void main(String[] args) { CallableThreadTest ctt = new CallableThreadTest(); FutureTask ft = new FutureTask<>(ctt); for(int i = 0;i < 10;i++) { System.out.println(Thread.currentThread().getName()+" 的循環(huán)變量i的值"+i); if(i%2==0) { new Thread(ft,"有返回值的線程").start(); } } try { System.out.println("子線程的返回值:"+ft.get()); } catch (InterruptedException e) { e.printStackTrace(); } catch (Exception e) { e.printStackTrace(); } } @Override public Integer call() throws Exception { int i = 0; for(;i<10;i++) { System.out.println(Thread.currentThread().getName()+" "+i); } return i; } }
4. synchronized關(guān)鍵字
4.1 概述
- synchronized關(guān)鍵字是為了解決共享資源競爭的問題,共享資源一般是以對象形式存在的內(nèi)存片段,但也可以是文件、輸入/輸出端口,或者是打印機(jī)。
- 要控制對共享資源的訪問,得先把它包裝進(jìn)一個對象。然后把所有要訪問的這個資源的方法標(biāo)記為synchronized。
- 如果某個任務(wù)處于一個對標(biāo)記為synchronized的方法的調(diào)用中,那么在這個線程從該方法返回之前,其他所有要調(diào)用類中任何標(biāo)記為synchronized方法的線程都會被阻塞。
4.2 基本原則
-
第一條:當(dāng)一個線程訪問某對象的
synchronized方法
或者synchronized代碼塊
時,其他線程對該對象的該synchronized方法
或者synchronized代碼塊
的訪問將被阻塞。 -
第二條:當(dāng)一個線程訪問某對象的
synchronized方法
或者synchronized代碼塊
時,其他線程仍然可以訪問該對象的非同步代碼塊。 -
第三條:當(dāng)一個線程訪問某對象的
synchronized方法
或者synchronized代碼塊
時,其他線程對該對象的其他的synchronized方法
或者synchronized代碼塊
的訪問將被阻塞。
4.3 實(shí)例
-
兩個相似的例子
- 實(shí)例1:實(shí)現(xiàn)接口Runnable
package com.ljw.thread; public class RunnableTest { public static void main(String[] args) { class MyRunnable implements Runnable{ @Override public void run() { synchronized (this) { for(int i=0;i<5;i++) { try { Thread.sleep(100); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println(Thread.currentThread().getName() + " 正在進(jìn)行打印 " +i); } } } } Runnable runnable = new MyRunnable(); Thread t1 = new Thread(runnable,"t1"); Thread t2 = new Thread(runnable,"t2"); t1.start(); t2.start(); } }
運(yùn)行結(jié)果:
t1 正在進(jìn)行打印 0 t1 正在進(jìn)行打印 1 t1 正在進(jìn)行打印 2 t1 正在進(jìn)行打印 3 t1 正在進(jìn)行打印 4 t2 正在進(jìn)行打印 0 t2 正在進(jìn)行打印 1 t2 正在進(jìn)行打印 2 t2 正在進(jìn)行打印 3 t2 正在進(jìn)行打印 4
結(jié)果說明:run()方法中存在synchronized(this)代碼塊,而且t1和t2都是基于MyRunnable這個Runnable對象創(chuàng)建的線程。這就意味著,我們可以將synchronized(this)中的this看做是MyRunnable這個Runnable對象;因此,線程t1和t2共享“MyRunable對象的同步鎖”。所以,當(dāng)一個線程運(yùn)行的時候,另外一個線程必須等待正在運(yùn)行的線程釋放MyRunnable的同步鎖之后才能運(yùn)行。
- 實(shí)例2:繼承Thread類
public class ThreadTest { public static void main(String[] args) { class MyThread extends Thread{ public MyThread(String name){ super(name); } @Override public void run() { synchronized(this){ for(int i=0;i<10;i++){ try { Thread.sleep(100); System.out.println(Thread.currentThread().getName()+" 正在進(jìn)行打印 "+i); } catch (InterruptedException e) { e.printStackTrace(); } } } } } Thread t1 = new MyThread("t1"); Thread t2 = new MyThread("t2"); t1.start(); t2.start(); } }
運(yùn)行結(jié)果:
t2 正在進(jìn)行打印 0 t1 正在進(jìn)行打印 0 t2 正在進(jìn)行打印 1 t1 正在進(jìn)行打印 1 t1 正在進(jìn)行打印 2 t2 正在進(jìn)行打印 2 t2 正在進(jìn)行打印 3 t1 正在進(jìn)行打印 3 t1 正在進(jìn)行打印 4 t2 正在進(jìn)行打印 4
對比結(jié)果:發(fā)現(xiàn)實(shí)例1的兩個線程是一個結(jié)束后,另一個才運(yùn)行,實(shí)例2的是交叉運(yùn)行,在run()方法中都有synchronized(this),為什么結(jié)果不一樣?
分析:synchronized(this)中的this是指當(dāng)前對象,即synchronized(this)所在類對應(yīng)的當(dāng)前對象。它的作用是獲取獲取當(dāng)前對象的同步鎖。對于實(shí)例2中的synchronized(this)中的this代表的是MyThread對象,t1和t2是兩個不同的MyThread對象,因此t1和t2在執(zhí)行synchronized(this)時獲取的是不同對象的同步鎖。對于實(shí)例1來說,synchronized(this)中的this代表的時候MyRunnable對象,t1和t2是共同一個MyRunnable對象,因此,一個線程獲取了對象的同步鎖,會造成另一個線程的等待。
4.4 synchronized方法和synchronized代碼塊
4.4.1 概述
-
synchronized方法
是用synchronized修飾方法,這是一種粗粒度鎖;這個同步方法(非static方法)無需顯式指定同步監(jiān)視器,同步方法的同步監(jiān)視器是this,也就是調(diào)用該方法的對象。 -
synchronized代碼塊
是用synchronized修飾代碼塊,這是一種細(xì)粒度鎖。線程開始執(zhí)行同步代碼塊之前,必須先獲得對同步監(jiān)視器的鎖定,任何時候只能有一個線程可以獲得對同步監(jiān)視器的鎖定,當(dāng)同步代碼塊執(zhí)行完成后,該線程會釋放對同步監(jiān)視器的鎖定。雖然Java允許使用任何對象作為同步監(jiān)視器,但同步監(jiān)視器的目的就是為了阻止兩個線程對同一個共享資源進(jìn)行并發(fā)訪問,因此通常推薦使用可能被并發(fā)訪問的共享資源充當(dāng)同步監(jiān)視器。
4.4.2 實(shí)例
public class SnchronizedTest {
public static void main(String[] args) {
class Demo {
// synchronized方法
public synchronized void synMethod() {
for(int i=0; i<1000000; i++)
;
}
public void synBlock() {
// synchronized代碼塊
synchronized( this ) {
for(int i=0; i<1000000; i++)
;
}
}
}
}
}
4.5 實(shí)例鎖和全局鎖
4.5.1 概述
- 實(shí)例鎖:鎖在某個實(shí)例對象上。如果該類是單例,那么該鎖也是具有全局鎖的概念。實(shí)例鎖對應(yīng)的就是synchronized關(guān)鍵字。
- 全局鎖:該鎖針對的是類,無論實(shí)例多少個對象,那么線程都共享該鎖。全局鎖對應(yīng)的就是static synchronized(或者是鎖在該類的class或者classloader對象上)。
4.5.2 實(shí)例
pulbic class Something {
public synchronized void isSyncA(){}
public synchronized void isSyncB(){}
public static synchronized void cSyncA(){}
public static synchronized void cSyncB(){}
}
假設(shè),類Something有兩個實(shí)例(對象)分別為x和y。分析下面4組表達(dá)式獲取鎖的情況。
-
x.isSyncA()與x.isSyncB()
- 不能同時訪問,因為都是訪問對象x的同步鎖
-
x.isSyncA()與y.isSyncA()
- 可以同時訪問,因為是訪問不同對象(x和y)的同步鎖
-
x.cSyncA()與y.cSyncB()
- 不能同時訪問,因為兩個方法是靜態(tài)的,相當(dāng)于用Something.cSyncA()和Something.cSyncB()訪問,是相同的對象
-
x.isSyncA()與Something.cSyncA()
- 可以同時訪問,因為訪問不同對象
5. Volatile 關(guān)鍵字
5.1 Volatile原理
- Java語言提供了一種稍微同步機(jī)制,即volatile變量,用來確保將變量的更新操作通知其他線程
- 在訪問volatile變量是不會執(zhí)行加鎖操作,因此也就不會重新執(zhí)行線程阻塞,volatile變量是一種比synchronized關(guān)鍵字輕量級的同步機(jī)制
- 當(dāng)一個變量被volatile修飾后,不但具有可見性,而且還禁止指令重排。volatile的讀性能消耗與普通變量幾乎相同,但是寫操作就慢一些,因為它要保證本地代碼中插入許多內(nèi)存屏障指令來保證處理器不發(fā)生亂序執(zhí)行
6. 線程等待和喚醒
6.1 常用方法
- 在Object.java中,定義了wait(),notify()和notifyAll()等接口
- wait()方法的作用是讓當(dāng)前線程進(jìn)入阻塞狀態(tài),同時會釋放當(dāng)前對象所持有的鎖
- notify()喚醒當(dāng)前對象上的等待線程,notifyAll()則是喚醒所有的線程
6.2 實(shí)例
package com.ljw.thread;
public class WaitDemo {
public static void main(String[] args) {
class ThreadTest extends Thread{
@Override
public void run() {
synchronized (this) {
System.out.println("開始運(yùn)行線程 "+Thread.currentThread().getName());
System.out.println("喚醒線程notify()");
notify();
}
}
}
ThreadTest thread1 = new ThreadTest();
thread1.start();
synchronized (thread1) {
try {
System.out.println("主線程進(jìn)入阻塞,釋放thread對象的同步鎖,wait()");
thread1.wait(); // wait()是讓當(dāng)前線程進(jìn)入阻塞狀態(tài),wait()是在主線程中執(zhí)行,
} catch (InterruptedException e) {
e.printStackTrace();
}
}
System.out.println("主線程繼續(xù)進(jìn)行");
}
}
7. 線程讓步和休眠
7.1 線程讓步
7.1.1 概述
- 在Java線程中,yield()方法的作用是讓步,它能讓當(dāng)前線程由“運(yùn)行狀態(tài)”進(jìn)入到“就緒狀態(tài)”,可能讓其它同級別的線程獲得執(zhí)行權(quán),但不一定,可能它自己再次由“就緒狀態(tài)”進(jìn)入到“運(yùn)行狀態(tài)”
7.1.2 實(shí)例
package com.ljw.thread;
public class YieldTest {
public static void main(String[] args) {
class ThreadA extends Thread{
public ThreadA(String name){
super(name);
}
@Override
public synchronized void run() {
for(int i=0;i<5;i++){
System.out.println(" "+this.getName()+" "+i);
if(i%2 == 0){
Thread.yield();
}
}
}
}
ThreadA t1 = new ThreadA("t1");
ThreadA t2 = new ThreadA("t2");
t1.start();
t2.start();
}
}
運(yùn)行結(jié)果(不唯一):
t1 0
t2 0
t1 1
t1 2
t2 1
t1 3
t2 2
t1 4
t2 3
t2 4
結(jié)果說明:
線程t1在能被2整除的時候,并不一定切換到線程2。這表明,yield()方法雖然可以讓線程由“運(yùn)行狀態(tài)”進(jìn)入到“就緒狀態(tài)”;但是,它不一定會讓其他線程獲取CPU執(zhí)行權(quán)(其他線程進(jìn)入到“運(yùn)行狀態(tài)”)。即時這個“其他線程”與當(dāng)前調(diào)用yield()的線程具有相同的優(yōu)先級。
7.1.3 yield()和wait()比較
- wait()的作用是讓當(dāng)前線程由“運(yùn)行狀態(tài)”進(jìn)入“阻塞狀態(tài)”,而yield()是讓當(dāng)前線程由“運(yùn)行狀態(tài)”進(jìn)入“就緒狀態(tài)”
- wait()是會讓線程釋放它所持有的對象的同步鎖,而yield()方法不會釋放對象的同步鎖。
7.2 線程休眠
7.2.1 概述
- sleep()方法定義在Thread類中,sleep()的作用是讓當(dāng)前線程休眠,即當(dāng)前線程會從“遠(yuǎn)程狀態(tài)”進(jìn)入到“休眠(阻塞)狀態(tài)”
- sleep()會指定休眠時間,線程休眠的時間會大于/等于該休眠時間
- 在線程重新被喚醒時,它會由“阻塞狀態(tài)”變成“就緒狀態(tài)”,從而等待CPU的調(diào)度執(zhí)行。
7.2.2 sleep() 和 wait()的比較
- wait()的作用是讓當(dāng)前的線程由“運(yùn)行狀態(tài)”進(jìn)入到“等待(阻塞)狀態(tài)”的同時,也會釋放同步鎖- 但是sleep()的作用是讓當(dāng)前線程由“運(yùn)行狀態(tài)”進(jìn)入到“休眠(阻塞)”狀態(tài),但不會釋放鎖。
8. 加入一個線程
8.1 概述
- 在一個線程T上調(diào)用另一個線程t的 join() 方法,相當(dāng)于在T中加入線程t,要等t結(jié)束后(即t.isAlive為假), join() 后面的代碼塊才會執(zhí)行。
- 可以在調(diào)用jion()時帶上一個超時參數(shù)(單位可以是毫秒,或者納秒),這樣如果目標(biāo)線程在這段時間到期時還沒有結(jié)束的話,join()方法總能返回
9. 終止一個線程
9.1 概述
- interrupt()并不會終止處于“運(yùn)行狀態(tài)”的線程,它會將線程的中斷標(biāo)記設(shè)為true。
- 綜合線程處于“阻塞狀態(tài)”和“運(yùn)行狀態(tài)”的終止方式,比較通用的終止線程的形式如下:
@Override
public void run() {
try {
// 1. isInterrupted()保證,只要中斷標(biāo)記為true就終止線程。
while (!isInterrupted()) {
// 執(zhí)行任務(wù)...
}
} catch (InterruptedException ie) {
// 2. InterruptedException異常保證,當(dāng)InterruptedException異常產(chǎn)生時,線程被終止。
}
}
9.2 實(shí)例
public class InterruptBlock {
/**
* @param args
*/
public static void main(String[] args) {
class MyThread extends Thread{
public MyThread(String name){
super(name);
}
@Override
public void run() {
try {
int i=0;
while(!isInterrupted()){
Thread.sleep(100);
i++;
System.out.println(Thread.currentThread().getName()+ " ("+this.getState()+") loop "+i);
}
} catch (InterruptedException e) {
e.printStackTrace();
System.out.println(Thread.currentThread().getName()+ " ("+this.getState()+") catch InterruptedExecption");
}
}
}
try {
//新建
Thread t1 = new MyThread("t1");
System.out.println(t1.getName()+" ("+t1.getState()+" ) is new.");
System.out.println("luo1:"+t1.isInterrupted());
//啟動
t1.start();
System.out.println(t1.getName()+" ("+t1.getState()+" ) is started.");
System.out.println("luo2:"+t1.isInterrupted());
//主線程休眠300ms,然后主線程給t1發(fā)“中斷”指令
Thread.sleep(300);
t1.interrupt();
System.out.println("luo3:"+t1.isInterrupted());
System.out.println(t1.getName()+" ("+t1.getState()+" ) is interrupted.");
//主線程休眠300ms,然后查看t1的狀態(tài)
Thread.sleep(300);
System.out.println(t1.getName()+" ("+t1.getState()+" ) is interrupted now .");
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
運(yùn)行結(jié)果:
t1 (NEW ) is new.
luo1:false
t1 (RUNNABLE ) is started.
luo2:false
t1 (RUNNABLE) loop 1
t1 (RUNNABLE) loop 2
luo3:true
t1 (RUNNABLE) loop 3
t1 (RUNNABLE ) is interrupted.
t1 (TERMINATED ) is interrupted now .
9.3 interrupt()和isInterrupted()的區(qū)別
- interrupt()和isInterrupted()都能夠用于檢測對象的“中斷標(biāo)記”。區(qū)別是:interrupt()除了返回中斷標(biāo)記之外,它還會清除中斷標(biāo)記(即將中斷標(biāo)記設(shè)為false);而isInterrupted()僅僅返回中斷標(biāo)記。
線程進(jìn)階
1. 線程池
- 示例
package com.ljw.thread;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class ThreadPoolDemo {
public static void main(String[] args) { // 主線程
// 線程池 ---> Executors工具類(工廠類)
/*
* newFixedThreadPool(int threadCount) 創(chuàng)建固定數(shù)量的線程池
* newCachedThreadPool() 創(chuàng)建動態(tài)數(shù)量的線程池
*/
ExecutorService es = Executors.newFixedThreadPool(3);
Runnable task = new MyTask();
// 提交任務(wù)
es.submit(task);
es.submit(task);
es.shutdown(); // 關(guān)閉線程池,則表示不在接收新任務(wù),不代表正在線程池的任務(wù)會停掉
}
}
class MyTask implements Runnable{
@Override
public void run() {
for(int i=0;i<100;i++) {
System.out.println(Thread.currentThread().getName()+" MyTask "+i);
}
}
}
2. 線程安全與鎖
2.1 重入鎖和讀寫鎖
package com.ljw.thread;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.locks.ReentrantLock;
import java.util.concurrent.locks.ReentrantReadWriteLock;
import java.util.concurrent.locks.ReentrantReadWriteLock.ReadLock;
import java.util.concurrent.locks.ReentrantReadWriteLock.WriteLock;
/**
* ReentrantLock類,重入鎖:Lock接口的實(shí)現(xiàn)類,與synchronized一樣具有互斥鎖功能 lock() 和 unlock()
* ReentrantReadWriteLock類,讀寫鎖:一種支持一寫多讀的同步鎖,讀寫分離,分別分配讀鎖和寫鎖,在讀操作遠(yuǎn)遠(yuǎn)高于寫操作的環(huán)境中可以提高效率
* 互斥規(guī)則:
* 寫--寫:互斥,阻塞
* 讀--寫:互斥,阻塞
* 讀--讀:不互斥,不阻塞
*
*/
public class LockDemo {
public static void main(String[] args) {
ExecutorService es = Executors.newFixedThreadPool(20);
Student s = new Student();
// ReentrantLock rLock = new ReentrantLock(); // 用ReenTrantLock加鎖運(yùn)行時間20008ms
ReentrantReadWriteLock rwLock = new ReentrantReadWriteLock(); // 用讀寫鎖分別對讀寫任務(wù)加鎖運(yùn)行時間3003ms
ReadLock rl = rwLock.readLock();
WriteLock wl = rwLock.writeLock();
// 寫任務(wù)
Callable writeTask = new Callable() {
@Override
public Object call() throws Exception {
// rLock.lock();
wl.lock();
try {
Thread.sleep(1000);
s.setValue(100);
}finally {
// rLock.unlock();
wl.unlock();
}
return null;
}};
// 讀任務(wù)
Callable readTask = new Callable() {
@Override
public Object call() throws Exception {
// rLock.lock();
rl.lock();
try {
Thread.sleep(1000);
s.getValue();
}finally {
// rLock.unlock();
rl.unlock();
}
return null;
}};
// 開始時間
long start = System.currentTimeMillis();
for(int i=0;i<2;i++) { // 寫任務(wù)執(zhí)行 2 次
es.submit(writeTask);
}
for(int i=0;i<18;i++) { // 讀任務(wù)執(zhí)行 18 次
es.submit(readTask);
}
es.shutdown(); // 停止線程池,不在接受新的任務(wù),將現(xiàn)有任務(wù)全部執(zhí)行完畢
while(true) {
if(es.isTerminated()) { // 當(dāng)線程池中所有任務(wù)執(zhí)行完畢,返回true,否則返回false
break;
}
}
// 執(zhí)行到這里,說明線程池中所有任務(wù)都執(zhí)行完畢,可以計算結(jié)束時間
System.out.println(System.currentTimeMillis()-start);
}
}
class Student {
private int value;
//讀
public int getValue() {
return value;
}
//寫
public void setValue(int value) {
this.value = value;
}
}
2.2 線程安全
2.2.1 Collections工具類
- Collections工具類中提供了多個可以獲得線程安全集合的方法
static Collection synchronizedCollection(Collection c)
//返回由指定集合支持的同步(線程安全)集合。
static List synchronizedList(List list)
//返回由指定列表支持的同步(線程安全)列表。
static Map synchronizedMap(Map m)
//返回由指定地圖支持的同步(線程安全)映射。
static NavigableMap synchronizedNavigableMap(NavigableMap m)
//返回由指定的可導(dǎo)航地圖支持的同步(線程安全)可導(dǎo)航地圖。
static NavigableSet synchronizedNavigableSet(NavigableSet s)
//返回由指定的可導(dǎo)航集支持的同步(線程安全)可導(dǎo)航集。
static Set synchronizedSet(Set s)
//返回由指定集合支持的同步(線程安全)集。
static SortedMap synchronizedSortedMap(SortedMap m)
//返回由指定的排序映射支持的同步(線程安全)排序映射。
static SortedSet synchronizedSortedSet(SortedSet s)
//返回由指定的排序集支持的同步(線程安全)排序集。,v>,v>,v>,v>,v>,v>,v>,v>,v>
2.2.2 CopyOnWriteArrayList
- 線程安全的ArrayList
- 讀寫分離,寫加鎖,讀沒鎖,讀寫之間不互斥
- 使用方法與ArrayList無異
2.2.3 CopyOnWriteArraySet
- 基于 CopyOnWriteArrayList
2.2.4 ConcurrentHashMap
- 初始容量默認(rèn)為16段(Segment),采用分段鎖設(shè)計
- 不對整個Map加鎖,只對每個Segment加鎖
- 當(dāng)多個對象訪問同個Segment才會互斥
審核編輯 黃昊宇
-
JAVA
+關(guān)注
關(guān)注
19文章
2966瀏覽量
104704 -
數(shù)據(jù)庫
+關(guān)注
關(guān)注
7文章
3794瀏覽量
64363 -
人工智能
+關(guān)注
關(guān)注
1791文章
47206瀏覽量
238276 -
python
+關(guān)注
關(guān)注
56文章
4792瀏覽量
84631
發(fā)布評論請先 登錄
相關(guān)推薦
評論