java并发:读写锁ReadWriteLock

在没有写操作的时候,两个线程同时读一个资源没有任何问题,允许多个线程同时读取共享资源。

但是如果有一个线程想去写这些共享资源,就不应该再有其它线程对该资源进行读或写。

简单来说,多个线程同时操作同一资源时,“读读共存,写写不共存,读写不共存”。

读写锁的锁定规则如下:
获得读锁后,其它线程可获得读锁而不能获取写锁
获得写锁后,其它线程既不能获得读锁也不能获得写锁

.

import java.util.concurrent.locks.ReadWriteLock;
import java.util.concurrent.locks.ReentrantReadWriteLock; /**
* 读写锁。
*/
public class ReadWriteLockDemo { public static void main(String[] args) {
ReadWrite readWrite=new ReadWrite(); for(int i=0;i<5;i++) {
new Thread(new Runnable() {
@Override
public void run() {
readWrite.get();
}
}).start(); new Thread(new Runnable() {
@Override
public void run() {
readWrite.set();
}
}).start();
}
}
} class ReadWrite {
private ReadWriteLock readWriteLock=new ReentrantReadWriteLock(); /**
* 进行"读"操作
*/
public void get() {
try {
readWriteLock.readLock().lock();
System.out.println("线程"+Thread.currentThread().getName()+"进行读取。");
Thread.sleep(2*1000);
}catch (InterruptedException e) {
e.printStackTrace();
}finally {
readWriteLock.readLock().unlock();
System.out.println("线程"+Thread.currentThread().getName()+"读取完毕。");
}
} /**
* 进行"写"操作
*/
public void set(){
try {
readWriteLock.writeLock().lock();
System.out.println("线程"+Thread.currentThread().getName()+"进行写入。");
Thread.sleep(2*1000);
}catch (InterruptedException e) {
e.printStackTrace();
}finally {
readWriteLock.writeLock().unlock();
System.out.println("线程"+Thread.currentThread().getName()+"写入完毕。");
}
}
}

示例结果如下:

线程Thread-0进行读取。
线程Thread-0读取完毕。
线程Thread-1进行写入。
线程Thread-1写入完毕。
线程Thread-5进行写入。
线程Thread-5写入完毕。
线程Thread-3进行写入。
线程Thread-3写入完毕。
线程Thread-7进行写入。
线程Thread-7写入完毕。
线程Thread-9进行写入。
线程Thread-9写入完毕。
线程Thread-2进行读取。
线程Thread-4进行读取。
线程Thread-6进行读取。
线程Thread-8进行读取。
线程Thread-2读取完毕。
线程Thread-6读取完毕。
线程Thread-8读取完毕。
线程Thread-4读取完毕。
上一篇:JUC——线程同步锁(ReentrantReadWriteLock读写锁)


下一篇:Cesium 获取鼠标当前位置的模型高度,地形高度,OSGB高度,及其经纬度。