ReentrantReadWriteLock類為讀寫鎖。 讀寫鎖也有兩個鎖，一個是讀操作相關的鎖，稱為共享鎖； 另一個是寫操作相關的鎖，也叫排他鎖。 也就是多個讀鎖之間不互斥，讀鎖與寫鎖互斥，寫鎖與寫鎖互斥。

一個線程擁有了對象A的寫鎖，在釋放寫鎖前其他線程無法獲得A的讀鎖、寫鎖，因此其他線程此時無法讀寫；
一個線程擁有了對象A的讀鎖，在釋放前其他線程可以獲得A的讀鎖但無法獲得A的寫鎖，因此其他線程此時可以讀不可以寫。
不加讀鎖的話其他線程是可以讀，但也可以寫，這時就可能導致數據不一致了

?

讀鎖共享

? ?使用lock.readLock()讀鎖可以提高程序運行效率，允許多個線程同時執行lock()方法后面的代碼

import java.util.concurrent.locks.ReentrantReadWriteLock;public class Service {private ReentrantReadWriteLock lock = new ReentrantReadWriteLock();public void read(){try {lock.readLock().lock();System.out.println("獲得讀鎖"+Thread.currentThread().getName()+" "+System.currentTimeMillis());Thread.sleep(10000);} catch (InterruptedException e) {e.printStackTrace();}finally {lock.readLock().unlock();}} }public class ThreadA extends Thread{private Service service = new Service();public ThreadA(Service service){super();this.service = service;}@Overridepublic void run(){service.read();} }public class ThreadB extends Thread{private Service service = new Service();public ThreadB(Service service){super();this.service = service;}@Overridepublic void run(){service.read();} }public class Run {public static void main(String[] args) {Service service = new Service();ThreadA a = new ThreadA(service);ThreadB b = new ThreadB(service);a.setName("A");b.setName("B");a.start();b.start();} }

?

寫鎖互斥

? 使用寫鎖代碼lock.writeLock()的效果就是同一時間只允許一個線程執行lock()方法后面的代碼

import java.util.concurrent.locks.ReentrantReadWriteLock;public class Service {private ReentrantReadWriteLock lock = new ReentrantReadWriteLock();public void writeLock(){try {lock.writeLock().lock();System.out.println("進入寫鎖:"+Thread.currentThread().getName()+" 時間:"+System.currentTimeMillis());Thread.sleep(10000);} catch (InterruptedException e) {e.printStackTrace();}finally{lock.writeLock().unlock();}} }public class ThreadA extends Thread{private Service service;public ThreadA(Service service){super();this.service = service;}@Overridepublic void run(){service.writeLock();} }public class ThreadB extends Thread{private Service service;public ThreadB(Service service){super();this.service = service;}@Overridepublic void run(){service.writeLock();} }public class Run {public static void main(String[] args){Service s = new Service();ThreadA a = new ThreadA(s);ThreadB b = new ThreadB(s);a.setName("A");b.setName("B");a.start();b.start();} }

?

總結

以上是生活随笔為你收集整理的线程:ReentrantReadWriteLock类的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。