1. 程式人生 > 實用技巧 >Java高併發,ReadWriteLock(讀寫鎖)

Java高併發,ReadWriteLock(讀寫鎖)

ReadWriteLock的作用,釋放了讀操作,不對讀加鎖,保證併發讀

總結:讀讀共存 讀寫不共存 寫寫不共存
上案例,程式碼如下:

public class ReadWriteLockDemo {
    public static void main(String[] args) {
        MyCache myCache = new MyCache();
        for (int i = 0; i < 5; i++) {
            final int finali= i;
            new Thread(() -> {
                
try { myCache.put(finali+"", finali+""); } catch (InterruptedException e) { e.printStackTrace(); } }, String.valueOf(i)).start(); } for (int i = 0; i < 5; i++) { final int finali= i;
new Thread(() -> { try { myCache.get(finali+""); } catch (InterruptedException e) { e.printStackTrace(); } }, String.valueOf(i)).start(); } } } class MyCache { private volatile Map<String, Object> map = new
HashMap<>(); public void put(String key, Object value) throws InterruptedException { System.out.println(Thread.currentThread().getName() + "\t-----寫入資料key"); Thread.sleep(3000); map.put(key, value); System.out.println(Thread.currentThread().getName() + "\t-----寫入資料成功"); } public void get(String key) throws InterruptedException { System.out.println(Thread.currentThread().getName() + "\t讀取資料key"); Thread.sleep(3000); Object result = map.get(key); System.out.println(Thread.currentThread().getName() + "\t讀取資料成功" + result); } }

執行結果如下:

我們可以看到的是在1進行寫入資料的時候,此時還沒有寫入成功,就已經對1進行了讀取操作,就像我們資料庫的原子性一樣,這裡在還沒有對資料進行寫入完成就進行了讀取的操作,所以讀取的為空。
接下來我們看看加入了讀寫鎖的效果,這裡只需要對MyCache進行修改:

加入ReadWriteLock

程式碼如下 :

class MyCache {
    private volatile Map<String, Object> map = new HashMap<>();
    private ReadWriteLock readWriteLock = new ReentrantReadWriteLock();

    public void put(String key, Object value) throws InterruptedException {
        readWriteLock.writeLock().lock();  //上寫鎖
        try {
            System.out.println(Thread.currentThread().getName() + "\t-----寫入資料key");
            Thread.sleep(3000);
            map.put(key, value);
            System.out.println(Thread.currentThread().getName() + "\t-----寫入資料成功");
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            readWriteLock.writeLock().unlock();
        }
    }
    public void get(String key) throws InterruptedException {
        readWriteLock.readLock().lock();  //上讀鎖
        try {
            System.out.println(Thread.currentThread().getName() + "\t讀取資料key");
            Thread.sleep(3000);
            Object result = map.get(key);
            System.out.println(Thread.currentThread().getName() + "\t讀取資料成功" + result);
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            readWriteLock.readLock().unlock();
        }
    }
}

執行結果如下:

可以看到我們對寫保持了一致性,讀保證了可併發讀,防止了在寫的時候進行了讀的操作導致的不一致性,所以這就是讀寫鎖的作用