JUC-07-读写锁

1. 简介

读：可以被多个线程同时读

写：只能有一个线程去写

2. 代码测试

2.1 未加锁

1. 自定义缓存

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

    // 存 ： 写
    public void put(String key, Object value){
        System.out.println(Thread.currentThread().getName()+"写入"+key);
        map.put(key,value);
        System.out.println(Thread.currentThread().getName()+"写入OK");
    }

    // 取 : 写
    public void get(String key){
        System.out.println(Thread.currentThread().getName()+"读取"+key);
        Object o = map.get(key);
        System.out.println(Thread.currentThread().getName()+"读取OK");
    }
}

2. 多线程操作缓存

public class ReadWriteLockDemo {

    /*
    自定义缓存
     */
    public static void main(String[] args) {
        MyCache myCache = new MyCache();

        // 写入
        for (int i = 0; i <= 5;i++){
            final int temp = i;
            new Thread(()->{
                myCache.put(temp+"",temp+"");
            },String.valueOf(i)).start();
        }

        // 读取
        for (int i = 0; i <= 5;i++){
            final int temp = i;
            new Thread(()->{
                myCache.get(temp+"");
            },String.valueOf(i)).start();
        }
    }

}

这种情况是有问题的：会有同时写入存在的情况

2.2 加锁

加入一把读写锁

1. 自定义缓存

class MyCache2{
    private volatile Map<String,Object> map = new HashMap<String, Object>();
    // 读写锁：更加细粒度的控制
    private ReadWriteLock readWriteLock = new ReentrantReadWriteLock();

    // 存 ： 写（只希望一个线程 去写）
    public void put(String key, Object value){
        // 写锁
        readWriteLock.writeLock().lock();

        try {
            System.out.println(Thread.currentThread().getName()+"写入"+key);
            map.put(key,value);
            System.out.println(Thread.currentThread().getName()+"写入OK");
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            readWriteLock.writeLock().unlock();
        }
    }

    // 取 : 写
    public void get(String key){

        // 读锁
        readWriteLock.readLock().lock();

        try {
            System.out.println(Thread.currentThread().getName()+"读取"+key);
            Object o = map.get(key);
            System.out.println(Thread.currentThread().getName()+"读取OK");
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            readWriteLock.readLock().unlock();
        }
    }
}

2. 多线程操作缓存

public class ReadWriteLockDemo {

    /*
    自定义缓存
     */
    public static void main(String[] args) {
        MyCache2 myCache2 = new MyCache2();

        // 写入
        for (int i = 0; i <= 5;i++){
            final int temp = i;
            new Thread(()->{
                myCache2.put(temp+"",temp+"");
            },String.valueOf(i)).start();
        }

        // 读取
        for (int i = 0; i <= 5;i++){
            final int temp = i;
            new Thread(()->{
                myCache2.get(temp+"");
            },String.valueOf(i)).start();
        }
    }

}

结果如下：问题解决！！！

3.小结

• 读-读：可以共存
• 读-写： 不能共存
• 写-写： 不能共存

独占锁：一次只能被一个线程占有（写锁）

共享锁：多个线程可以同时占有（读锁）

打赏