编程语言
首页 > 编程语言> > Java并发多线程编程——ReentrantReadWriteLock中的锁降级详解

Java并发多线程编程——ReentrantReadWriteLock中的锁降级详解

作者:互联网

一、ReentrantReadWriteLock中的降级锁

二、ReentrantReadWriteLock降级锁的代码示例

package com.xz.thread.t12;

import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReadWriteLock;
import java.util.concurrent.locks.ReentrantReadWriteLock;

/**
 * @description: ReentrantReadWriteLock降级锁示例
 * @author: xz
 * @create: 2021-05-17 22:09
 */
public class Demo {
    /**
     *    1、ReentrantReadWriteLock实例实现了ReadWriteLock接口
     *    2、声明一个ReentrantReadWriteLock实例,指向父类ReadWriteLock的引用
     *       因为ReentrantReadWriteLock可以保证公平或者非公平
     *    3、ReadWriteLock类中只有readLock()和writeLock() 两个方法
     */
    private ReadWriteLock rwl =new ReentrantReadWriteLock();

    //读锁
    private Lock r =rwl.readLock();
    //写锁
    private Lock w =rwl.writeLock();

    //声明一个map,存储数据
    private Map<String,Object> map =new HashMap<>();
    //声明一个boolean类型的状态,用于判断是读操作还是写操作;volatile关键字保证可见性
    private volatile boolean isUpdateStatus;

    //定义一个读写方法
    public void readWriteMethod(){
        r.lock();//为了保证isUpdateStatus能够获取到最新的值,添加读锁
        if(isUpdateStatus){//如果isUpdateStatus是最新的值
            r.unlock();//因为要进行写操作,所以需要释放读锁
            w.lock();//在写操作之前,为了保证写的状态,需要加写锁
            map.put("key1","v1");//写操作
            //开始锁降级;
            //再写操作没有释放的时候,获取到读锁,再释放写锁
            r.lock();
            w.unlock();//写操作完成后释放写锁
            //锁降级完成;
        }
        Object obj = map.get("key1");//写操作
        r.unlock();//释放读锁
        System.out.println(Thread.currentThread().getName()+"读操作获取到的值:"+obj);

    }

}

标签:降级,Java,ReentrantReadWriteLock,ReadWriteLock,util,读锁,import,多线程
来源: https://blog.csdn.net/li1325169021/article/details/116952532