当被面试官问到：JUC并发编程——读写锁 ReadWriteLock

2、ReadWriteLock 使用

==================

模拟缓存数据的写入和读取

不加读写锁的情况

package com.cheng.rw;

import java.util.HashMap;

import java.util.Map;

public class ReadWriteLock {

public static void main(String[] args) {

MyCache myCache = new MyCache();

//写操作

for (int i = 0; i < 5; i++) {

final int temp = i;

new Thread(()->{

myCache.set(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();

}

}

}

class MyCache{

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

//写操作

public void set(String key,Object value){

System.out.println(Thread.currentThread().getName()+“写入了”+key);

map.put(key,value);

System.out.println(Thread.currentThread().getName()+“写入操作完成”);

}

//读操作

public void get(String key){

System.out.println(Thread.currentThread().getName()+“读取了”+key);

Object o = map.get(key);

System.out.println(Thread.currentThread().getName()+“读取操作完成”);

}

}

运行查看结果：

不加读写锁，当前线程在进行写入操作时被其他线程插队。

加上读写锁

package com.cheng.rw;

import java.util.HashMap;

import java.util.Map;

import java.util.concurrent.locks.ReentrantReadWriteLock;

public class ReadWriteLock {

public static void main(String[] args) {

MyCacheLock myCache = new MyCacheLock();

//写操作

for (int i = 0; i < 5; i++) {

final int temp = i;

new Thread(()->{

myCache.set(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();

}

}

}

class MyCacheLock{

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

Kafka实战笔记

关于这份笔记，为了不影响大家的阅读体验，我只能在文章中展示部分的章节内容和核心截图

• Kafka入门
• 为什么选择Kafka
• Karka的安装、管理和配置

• Kafka的集群
• 第一个Kafka程序
• 

afka的生产者

• Kafka的消费者
• 深入理解Kafka
• 可靠的数据传递

• Spring和Kalka的整合
• Sprinboot和Kafka的整合
• Kafka实战之削峰填谷
• 数据管道和流式处理(了解即可)

• Kafka实战之削峰填谷

QJYz-1714697766896)]

• Spring和Kalka的整合
• Sprinboot和Kafka的整合
• Kafka实战之削峰填谷
• 数据管道和流式处理(了解即可)

[外链图片转存中…(img-n5ooxyi0-1714697766897)]

• Kafka实战之削峰填谷

[外链图片转存中…(img-aY2xCHme-1714697766897)]

本文已被CODING开源项目：【一线大厂Java面试题解析+核心总结学习笔记+最新讲解视频+实战项目源码】收录