一、讀寫鎖

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

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

二、悲觀讀鎖

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

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

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

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

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

三、樂觀讀

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

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

public String readWithOptimisticLock(String key) {
    long stamp = lock.tryOptimisticRead(); //樂觀讀
    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高性能讀寫鎖詳解的詳細(xì)內(nèi)容，更多關(guān)于java并發(fā)StampedLock讀寫鎖的資料請關(guān)注腳本之家其它相關(guān)文章！

最新評(píng)論