4:Lockers和Condition接口
在多線程編程里面一個(gè)重要的概念是鎖定,如果一個(gè)資源是多個(gè)線程共享的,為了保證數(shù)據(jù)的完整性,在進(jìn)行事務(wù)性操作時(shí)需要將共享資源鎖定,這樣可以保證在做事務(wù)性操作時(shí)只有一個(gè)線程能對資源進(jìn)行操作,從而保證數(shù)據(jù)的完整性。在5.0以前,鎖定的功能是由Synchronized關(guān)鍵字來實(shí)現(xiàn)的,這樣做存在幾個(gè)問題:
每次只能對一個(gè)對象進(jìn)行鎖定。若需要鎖定多個(gè)對象,編程就比較麻煩,一不小心就會出現(xiàn)死鎖現(xiàn)象。
如果線程因拿不到鎖定而進(jìn)入等待狀況,是沒有辦法將其打斷的
在Java 5.0里出現(xiàn)兩種鎖的工具可供使用,下圖是這兩個(gè)工具的接口及其實(shí)現(xiàn):
Lock接口
ReentrantLock是Lock的具體類,Lock提供了以下一些方法:
lock(): 請求鎖定,如果鎖已被別的線程鎖定,調(diào)用此方法的線程被阻斷進(jìn)入等待狀態(tài)。
tryLock():如果鎖沒被別的線程鎖定,進(jìn)入鎖定狀態(tài),并返回true。若鎖已被鎖定,返回false,不進(jìn)入等待狀態(tài)。此方法還可帶時(shí)間參數(shù),如果鎖在方法執(zhí)行時(shí)已被鎖定,線程將繼續(xù)等待規(guī)定的時(shí)間,若還不行才返回false。
unlock():取消鎖定,需要注意的是Lock不會自動取消,編程時(shí)必須手動解鎖。
代碼:
//生成一個(gè)鎖
Lock lock = new ReentrantLock();
public void accessProtectedResource() {
lock.lock(); //取得鎖定
try {
//對共享資源進(jìn)行操作
} finally {
//一定記著把鎖取消掉,鎖本身是不會自動解鎖的
lock.unlock();
}
}
ReadWriteLock接口
為了提高效率有些共享資源允許同時(shí)進(jìn)行多個(gè)讀的操作,但只允許一個(gè)寫的操作,比如一個(gè)文件,只要其內(nèi)容不變可以讓多個(gè)線程同時(shí)讀,不必做排他的鎖定,排他的鎖定只有在寫的時(shí)候需要,以保證別的線程不會看到數(shù)據(jù)不完整的文件。ReadWriteLock可滿足這種需要。ReadWriteLock內(nèi)置兩個(gè)Lock,一個(gè)是讀的Lock,一個(gè)是寫的Lock。多個(gè)線程可同時(shí)得到讀的Lock,但只有一個(gè)線程能得到寫的Lock,而且寫的Lock被鎖定后,任何線程都不能得到Lock。ReadWriteLock提供的方法有:
readLock(): 返回一個(gè)讀的lock
writeLock(): 返回一個(gè)寫的lock, 此lock是排他的。
ReadWriteLock的例子:
public class FileOperator{
//初始化一個(gè)ReadWriteLock
ReadWriteLock lock = new ReentrantReadWriteLock();
public String read() {
//得到readLock并鎖定
Lock readLock = lock.readLock();
readLock.lock();
try {
//做讀的工作
return "Read something";
} finally {
readLock.unlock();
}
}
public void write(String content) {
//得到writeLock并鎖定
Lock writeLock = lock.writeLock();
writeLock.lock();
try {
//做讀的工作
} finally {
writeLock.unlock();
}
}
}
相關(guān)推薦:計(jì)算機(jī)等級考試二級Java經(jīng)典算法大全匯總北京 | 天津 | 上海 | 江蘇 | 山東 |
安徽 | 浙江 | 江西 | 福建 | 深圳 |
廣東 | 河北 | 湖南 | 廣西 | 河南 |
海南 | 湖北 | 四川 | 重慶 | 云南 |
貴州 | 西藏 | 新疆 | 陜西 | 山西 |
寧夏 | 甘肅 | 青海 | 遼寧 | 吉林 |
黑龍江 | 內(nèi)蒙古 |