一、讀寫(xiě)鎖

在我的《java并發(fā)編程》上一篇文章中為大家介紹了《ReentrantLock讀寫(xiě)鎖》,ReentrantReadWriteLock可以保證最多同時(shí)有一個(gè)線程在寫(xiě)數(shù)據(jù)，或者可以同時(shí)有多個(gè)線程讀數(shù)據(jù)，但讀寫(xiě)不能同時(shí)進(jìn)行。

比如你正在做的是日志，有一個(gè)線程正在做寫(xiě)操作，但是在寫(xiě)日志的時(shí)候你可能需要把日志集中轉(zhuǎn)移到集中管理日志服務(wù)，但是此時(shí)讀線程不能讀數(shù)據(jù)(因?yàn)闊o(wú)法獲取讀鎖)。面對(duì)這個(gè)需求，ReentrantReadWriteLock顯然不是我們的解決方案，我們希望：最多一個(gè)線程在進(jìn)行寫(xiě)操作(加寫(xiě)鎖)，但是同時(shí)允許多個(gè)線程進(jìn)行讀操作（加讀鎖），解決方案是StampedLock。

二、悲觀讀鎖

StampedLock 同樣可以實(shí)現(xiàn)寫(xiě)鎖和讀鎖的功能，Stamped在英文中有印章的含義，對(duì)于StampedLock大家可以這么理解，使用一個(gè)印章加鎖，必須使用該印章解鎖。

public class TestStampedLock {
    Map<String,String> map = new HashMap<>();
    //鎖對(duì)象
    private StampedLock lock = new StampedLock();
    //寫(xiě)操作函數(shù)
    public void put(String key, String value){
        long stamp = lock.writeLock(); //加寫(xiě)鎖
        try {
            map.put(key, value); //寫(xiě)操作
        } finally {
            lock.unlockWrite(stamp);  //釋放寫(xiě)鎖
        }
    }
    public String get(String key) {
        long stamp = lock.readLock(); //加讀鎖
        try {
            return map.get(key); //讀操作
        } finally {
            lock.unlockRead(stamp); //釋放讀鎖
        }
    }
}

上文中的讀鎖readLock，在StampedLock模式中被稱為悲觀讀鎖，之所以叫做悲觀讀鎖是和StampedLock支持的另一種模式“樂(lè)觀讀”相對(duì)應(yīng)的。

寫(xiě)鎖、悲觀讀鎖的語(yǔ)義和 ReadWriteLock 的寫(xiě)鎖、讀鎖的語(yǔ)義基本是一致的，允許多個(gè)線程同時(shí)獲取悲觀讀鎖，但是只允許一個(gè)線程獲取寫(xiě)鎖，寫(xiě)鎖和悲觀讀鎖是互斥的。

多線程環(huán)境下，寫(xiě)操作的同時(shí)不能讀。所以到這里為止，StampedLock與ReadWriteLock并沒(méi)有很大的區(qū)別。

三、樂(lè)觀讀

需要注意的是，這里我寫(xiě)的是樂(lè)觀讀，而不是樂(lè)觀讀鎖，因?yàn)闃?lè)觀讀是不加鎖的。通過(guò)tryOptimisticRead()函數(shù)獲取一個(gè)stamp，這里的tryOptimisticRead() 就是樂(lè)觀讀，樂(lè)觀讀因?yàn)闆](méi)有加鎖，所以讀取數(shù)據(jù)的性能會(huì)更高一點(diǎn)。即：已經(jīng)有寫(xiě)操作線程加鎖的同時(shí)，仍然允許讀操作線程繼續(xù)進(jìn)行。

如果你的讀寫(xiě)操作有比較強(qiáng)的時(shí)間點(diǎn)數(shù)據(jù)一致性要求，即：同一個(gè)時(shí)間點(diǎn)讀操作讀到的數(shù)據(jù)，一定與該時(shí)間點(diǎn)寫(xiě)操作保持?jǐn)?shù)據(jù)一致性。那么，你就需要進(jìn)行validate校驗(yàn)，stamp此時(shí)可以理解為一個(gè)版本號(hào)，如果寫(xiě)操作版本為2，讀操作版本為1，說(shuō)明你讀到的數(shù)據(jù)不是最新的。你需要去讀取最新版本的數(shù)據(jù)（版本號(hào)為2），所以需要升級(jí)為悲觀讀鎖，代碼如下：

public String readWithOptimisticLock(String key) {
    long stamp = lock.tryOptimisticRead(); //樂(lè)觀讀
    String value = map.get(key); //讀取數(shù)據(jù)
    if(!lock.validate(stamp)) {  //校驗(yàn)數(shù)據(jù)是否是最新版本
        stamp = lock.readLock();  //如果不是，升級(jí)為悲觀讀鎖
        try {
            return map.get(key);
        } finally {
            lock.unlock(stamp);               
        }
    }
    return value;
}

以上就是java并發(fā)編程StampedLock高性能讀寫(xiě)鎖詳解的詳細(xì)內(nèi)容，更多關(guān)于java并發(fā)StampedLock讀寫(xiě)鎖的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！

最新評(píng)論