線程同步:1. 多線程讀寫競爭資源需要同步2. Java語言提供了synchronized/wait/notify來實現(xiàn)線程的同步3. 但是編寫多線程的同步仍然很困難所以JDK提供的高級的java.util.concurrent包1. concurrent包可以提供更高級的同步功能2. 同時可以簡化多線程程序的編寫3. JDK1.5提供的

因為synchronized是JAVA提供的,所以不需要考慮異常.但是如果我們使用ReentrantLock,是一個普通的JAVA類,所以我們要用try...finally的這樣的結(jié)構(gòu)來保證鎖的釋放,

首先我們new ReentrankLock()來創(chuàng)建一個對象,然后我們要試圖用lock.lock()方法獲取鎖,如果我們獲取成功,就進入try代碼,在finally里面使用lock.unlock()來釋放鎖.這里必須要注意的是lock.lock()必須在try之外完成.因為lock.lock()方法可能會失敗,而unlock方法一定要在finally里面完成ReentrantLock也是一種可重入的鎖:1. 可重入的鎖,一個線程可多次獲取同一個鎖2. lock()方法就是用來獲取鎖的3. tryLock()方法可嘗試獲取鎖并可指定超時使用ReentrankLock比synchronized更安全synchronized要么獲得鎖,要么永遠的等待下去,而使用ReentrankLock的時候,我們可以使用tryLock()在失敗的時候,不會導致死鎖. package com.leon.day05;import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock;class Counter {// 首先初始化一個ReentrantLock實例,然后向上轉(zhuǎn)型為Lock接口private Lock lock = new ReentrantLock();private int value = 0;public void add(int m) {lock.lock();try { this.value += m;}finally {lock.unlock();}}public void dec(int m) {lock.lock();try {this.value -= m;}finally {lock.unlock();}}public int get() {lock.lock();try {return this.value;}finally {lock.unlock();}}}public class Main {final static int LOOP = 100;// 在main方法中啟動兩個線程,分別調(diào)用add和dec方法,public static void main(String[] args) throws InterruptedException {Counter counter = new Counter();Thread t1 = new Thread() {@Overridepublic void run() {for(int i=0;i<LOOP;i++) {counter.add(1);}}};Thread t2 = new Thread() {@Overridepublic void run() {for(int i=0;i<LOOP;i++) {counter.dec(1);}}};t1.start();t2.start();t1.join();t2.join();System.out.println(counter.get());}}

ReentrantLock可以替代synchronizedReentrantLock獲取鎖更安全必須使用try...finally保證正確獲取和釋放鎖

臨界區(qū)就是任何時候只有一個線程能夠執(zhí)行的代碼塊,但是有些時候這種保護有點過頭任何時候只允許一個線程修改,對inc()方法加鎖也是必須的,但是get()方法只讀取數(shù)據(jù),不修改數(shù)據(jù),允許多個線程同時調(diào)用我們希望允許多個線程同時讀,但只要一個線程在寫,其他線程就必須等待.多線程同時讀是允許的,我們只是不允許多線程同時寫,或者同時讀寫.我們可以使用ReadWriteLock可以解決:1. 只允許一個線程寫入,(其它線程既不能寫入也不能讀取)2. 但是在沒有線程寫入的時候,多個線程允許同時讀(提高性能)

首先創(chuàng)建一個ReadWriteLock的實例,然后分別獲取readLock()和writeLock().變量rLock代表readLock,而wLock代表writeLock,在寫方法中使用wLock.lock()加鎖而在讀方法中使用rLock.lock()加鎖,這樣我們就可以大大的提高讀取的效率. package com.leon.day05;import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReadWriteLock; import java.util.concurrent.locks.ReentrantReadWriteLock;class Counter {// 首先創(chuàng)建一個ReadWriteLock的實例private ReadWriteLock lock = new ReentrantReadWriteLock();// 然后通過readLock獲取讀鎖private Lock rLock = lock.readLock();// 通過writeLock獲取寫鎖private Lock wLock = lock.writeLock();private int value = 0;// add方法是一個修改方法,所以用wLock,解鎖加鎖public void add(int m) {wLock.lock();try { this.value += m;}finally {wLock.unlock();}}// 對于dec方法也是寫鎖public void dec(int m) {wLock.lock();try {this.value -= m;}finally {wLock.unlock();}}// 但是對于get方法只需要使用一個讀鎖,這樣多個線程就可以獲取讀鎖public int get() {rLock.lock();try {return this.value;}finally {rLock.unlock();}}}public class Main {final static int LOOP = 100;// 在main方法中啟動兩個線程,分別調(diào)用add和dec方法,public static void main(String[] args) throws InterruptedException {Counter counter = new Counter();Thread t1 = new Thread() {@Overridepublic void run() {for(int i=0;i<LOOP;i++) {counter.add(1);}}};Thread t2 = new Thread() {@Overridepublic void run() {for(int i=0;i<LOOP;i++) {counter.dec(1);}}};t1.start();t2.start();t1.join();t2.join();System.out.println(counter.get());}} ReadWriteLock適用的條件:1. 適用同一個實例,有大量線程讀取,僅有少數(shù)線程修改：例如一個論壇的帖子,瀏覽可以看成是讀取,但是非常頻繁的,發(fā)布寫入是不頻繁的. 這種情況下就可以使用ReadWriteLock. 使用ReadWriteLock可以提高讀取的效率1. ReadWrite只允許一個線程寫入2. 但是允許多個線程同時讀取3. 特別適合讀多寫少的場景

?

總結(jié)

以上是生活随笔為你收集整理的高级concurrent包的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。