JUC-ReenactmentReadWriteLock使用

计划一个缓存类

可以向其中put数据(写操作)

也可以向其中get数据(读操作)

public class ReentrantReadWriteLockTest {

    public static void main(String[] args) {
        MyCache myCache = new MyCache();

        for (int i = 1; i <= 10; i++) {
            final int temp = i;
            new Thread(()-> {
                myCache.put(temp + "", temp + "");
            }, String.valueOf(i)).start();
        }

        for (int i = 1; i <= 10; i++) {
            final int temp = i;
            new Thread(()-> {
                myCache.get(temp + "");
            }, String.valueOf(i)).start();
        }
    }
}

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

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

    public String get(String key) {
        System.out.println(Thread.currentThread().getName() + "读取" + key);
        String s = map.get(key);
        System.out.println(Thread.currentThread().getName() + "读取ok");
        return s;
    }
}
/**
 * 2写入2
 * 5写入5
 * 5写入ok
 * 7写入7
 * 7写入ok
 * 2写入ok
 * 4写入4
 * 4写入ok
 * 1写入1
 * 1写入ok
 * 6写入6
 * 6写入ok
 * 3写入3
 * 3写入ok
 * 9写入9
 * 10写入10
 * 10写入ok
 * 8写入8
 * 8写入ok
 * 9写入ok
 * 1读取1
 * 1读取ok
 * 2读取2
 * 2读取ok
 * 3读取3
 * 3读取ok
 * 4读取4
 * 6读取6
 * 6读取ok
 * 5读取5
 * 5读取ok
 * 7读取7
 * 7读取ok
 * 9读取9
 * 10读取10
 * 10读取ok
 * 4读取ok
 * 9读取ok
 * 8读取8
 * 8读取ok
 */

不做锁处理,结果输出有误2线程还没写完,5线程就进来写了

使用ReentrantReadWriteLock,完成细粒度锁控制

读-读,可共存

写-读,不可共存

写-写,不可共存

public class ReentrantReadWriteLockTest {

    public static void main(String[] args) {
        MyCacheLock myCache = new MyCacheLock();

        for (int i = 1; i <= 10; i++) {
            final int temp = i;
            new Thread(()-> {
                myCache.put(temp + "", temp + "");
            }, String.valueOf(i)).start();
        }

        for (int i = 1; i <= 10; i++) {
            final int temp = i;
            new Thread(()-> {
                myCache.get(temp + "");
            }, String.valueOf(i)).start();
        }
    }
}

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

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

    public String get(String key) {
        System.out.println(Thread.currentThread().getName() + "读取" + key);
        String s = map.get(key);
        System.out.println(Thread.currentThread().getName() + "读取ok");
        return s;
    }
}

class MyCacheLock {
    private volatile Map<String, String> map = new HashMap<>();
    private ReadWriteLock readWriteLock = new java.util.concurrent.locks.ReentrantReadWriteLock();

    public void put(String key, String 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 String get(String key) {
        // 读取操作使用读锁,加锁
        readWriteLock.readLock().lock();
        String s = null;
        try {
            System.out.println(Thread.currentThread().getName() + "读取" + key);
            s = map.get(key);
            System.out.println(Thread.currentThread().getName() + "读取ok");
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            readWriteLock.readLock().unlock();
        }
        return s;
    }
}
/**
 * 1写入1
 * 1写入ok
 * 6写入6
 * 6写入ok
 * 2写入2
 * 2写入ok
 * 7写入7
 * 7写入ok
 * 3写入3
 * 3写入ok
 * 4写入4
 * 4写入ok
 * 5写入5
 * 5写入ok
 * 8写入8
 * 8写入ok
 * 10写入10
 * 10写入ok
 * 9写入9
 * 9写入ok
 * 6读取6
 * 8读取8
 * 8读取ok
 * 5读取5
 * 5读取ok
 * 2读取2
 * 2读取ok
 * 4读取4
 * 4读取ok
 * 1读取1
 * 1读取ok
 * 7读取7
 * 7读取ok
 * 3读取3
 * 3读取ok
 * 10读取10
 * 10读取ok
 * 9读取9
 * 6读取ok
 * 9读取ok
 */

可以发现,写必须等待上一个线程写完之后才可以进行写操作,读可以不用等待读操作,但还是需要等待写操作线程释放锁。

#JUC#
全部评论

相关推荐

真tmd的恶心,1.面试开始先说我讲简历讲得不好,要怎样讲怎样讲,先讲背景,再讲技术,然后再讲提升多少多少,一顿说教。2.接着讲项目,我先把背景讲完,开始讲重点,面试官立即打断说讲一下重点,无语。3.接着聊到了项目的对比学习的正样本采样,说我正样本采样是错的,我解释了十几分钟,还是说我错的,我在上一家实习用这个方法能work,并经过市场的检验,并且是顶会论文的复现,再怎么不对也不可能是错的。4.面试官,说都没说面试结束就退出会议,把面试者晾在会议里面,丝毫不尊重面试者难受的点:1.一开始是讲得不好是欣然接受的,毕竟是学习。2.我按照面试官的要求,先讲背景,再讲技术。当我讲完背景再讲技术的时候(甚至已经开始蹦出了几个技术名词),凭什么打断我说讲重点,是不能听出人家重点开始了?这也能理解,每个人都有犯错,我也没放心上。3.我自己做过的项目,我了解得肯定比他多,他这样贬低我做过的项目,说我的工作是错误的,作为一个技术人员,我是完全不能接受的,因此我就和他解释,但无论怎么解释都说我错。凭什么,作为面试官自己不了解相关技术,别人用这个方式work,凭什么还认为这个方法是错的,不接受面试者的解释。4.这个无可厚非,作为面试官,不打招呼就退出会议,把面试者晾着,本身就是有问题。综上所述,我现在不觉得第一第二点也是我的问题,面试官有很大的问题,就是专门恶心人的,总结面试官说教,不尊重面试者,打击面试者,不接受好的面试者,技术一般的守旧固执分子。有这种人部门有这种人怎么发展啊。最后去查了一下,岗位关闭了。也有可能是招到人了来恶心人的,但是也很cs
牛客20646354...:招黑奴啊,算法工程师一天200?
点赞 评论 收藏
分享
评论
点赞
1
分享

创作者周榜

更多
牛客网
牛客网在线编程
牛客网题解
牛客企业服务