Java高併發,ReadWriteLock(讀寫鎖)
阿新 • • 發佈:2020-08-22
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 = newHashMap<>(); 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(); } } }
執行結果如下:
可以看到我們對寫保持了一致性,讀保證了可併發讀,防止了在寫的時候進行了讀的操作導致的不一致性,所以這就是讀寫鎖的作用