跑起一个程序,并不难;难的是,能让程序跑多远!—— 一颗剽悍的种子
JUC并发系列
JUC并发系列(一):什么?听说你搞混了并发和并行
JUC并发系列(二):详解Condition实现精准通知唤醒
JUC并发系列(三):面试问并发,一问锁就懵(怒肝一篇透彻理解锁,面试不慌)
JUC并发系列(四):【面试常问】多种方法解决ArrayList非线程安全,详解CopyOnWriteArrayList
JUC并发系列(五):CopyOnWriteArraySet解决HashSet非线程安全
JUC并发系列(六):ConcurrentHashMap解决HashMap非线程安全
JUC并发系列(七):触及Callable
JUC并发系列(八):并发编程常用辅助类CountDownLatch与CyclicBarrier
JUC并发系列(九):并发编程常用辅助类Semaphore
准确来说 ReadWriteLock读写锁,应该是 读/写锁,正如ReadWriteLock 读/写锁也是分开来的,它管理着两个为一组的锁,一个是只读锁,一个是写锁。
通过字面意思告诉你 ReadWriteLock读/写锁 其实你是很难理解的,因为只有通过案例,只有通过一行行代码去验证,你才能在深深的理解后有自己的总结。
有自己总结过后的知识才是你的,因为那是知识的结晶。
(技术之余总会扯这些有的没的,只想告诉你不要光看我的博文,学习这种活,也只有你理解透后,用自己所能理解的语言重塑,才是你自己的。)
我们接下来用两个小案例,首先是一个没有使用锁和使用ReadWriteLock读写锁后的形式对比来学习。
我们通过一个缓存的小案例来,在没有使用锁的情况下,实现存储和读取的功能,并通过在多个线程的并发下。
public class Demo{
public static void main(String[] args) {
Cache cache = new Cache();
//存储
for (int i = 1; i <= 3; i++) {
final Integer index = i;
new Thread(()->{
cache.put(index+"",index);
},String.valueOf(i)).start();
}
//读取
for (int i = 1; i <= 3; i++) {
final Integer index = i;
new Thread(()->{
cache.get(index+"");
},String.valueOf(i)).start();
}
}
}
class Cache{
private Map<String,Integer> map = new HashMap<>();
//存储
public void put(String key,Integer value){
System.out.println("线程"+Thread.currentThread().getName() + "===存储" + value);
map.put(key,value);
System.out.println("线程"+Thread.currentThread().getName() + "===已存储");
}
//读取
public void get(String key){
System.out.println("线程"+Thread.currentThread().getName() + "===读取");
map.get(key);
System.out.println("线程"+Thread.currentThread().getName() + "===已读取");
}
}
观察上面的代码所运行的结果会发现两点:
如果你理解了上面为什么ReadWriteLock读/写锁是分成两个为一组的读/写,其实你在实际运用中也就能更深刻透彻。
我们缓存 put 是存储就是写入,可以用 writeLock写锁。
而读取 get 可以用读锁。
可以看到不会像synchronized直接锁或lock,它们更加细致,也更具有针对性的分而治之。
这里的写锁可以说是共享锁,独占锁又称排他锁。
共享锁(写锁):一次只能一个线程持有。
readWriteLock.writeLock().lock();
共享锁(读锁):多个线程可以同时持有。
readWriteLock.readLock().lock();
读/写锁使用后都需要分别关闭,跟Lock最后也需要手动关闭是一样一样的。
readWriteLock.writeLock().unlock();
readWriteLock.readLock().unlock();
public class Demo{
public static void main(String[] args) {
Cache cache = new Cache();
//存储
for (int i = 1; i <= 3; i++) {
final Integer index = i;
new Thread(()->{
cache.put(index+"",index);
},String.valueOf(i)).start();
}
//读取
for (int i = 1; i <= 3; i++) {
final Integer index = i;
new Thread(()->{
cache.get(index+"");
},String.valueOf(i)).start();
}
}
}
class Cache{
private Map<String,Integer> map = new HashMap<>();
private ReadWriteLock readWriteLock = new ReentrantReadWriteLock();
//存储
public void put(String key,Integer value){
readWriteLock.writeLock().lock();
try {
System.out.println("线程"+Thread.currentThread().getName() + "===存储" + value);
map.put(key,value);
System.out.println("线程"+Thread.currentThread().getName() + "===已存储");
} catch (Exception e) {
e.printStackTrace();
} finally {
readWriteLock.writeLock().unlock();
}
}
//读取
public void get(String key){
readWriteLock.readLock().lock();
try {
System.out.println("线程"+Thread.currentThread().getName() + "===读取");
map.get(key);
System.out.println("线程"+Thread.currentThread().getName() + "===已读取");
} catch (Exception e) {
e.printStackTrace();
} finally {
readWriteLock.readLock().unlock();
}
}
}
可以看到和上面没有加锁的运行结果,加了ReadWriteLock读写锁 后很直观的结果。在多线程并发下存储的时候会有秩序的执行。
从 ReadWriteLock读/写锁 的不仅概念或者案例的对比和验证中可以很直观的发现其特性。
使用 ReadWriteLock读/写锁 时, 适用少数线程修改操作,但可以有大量线程读取。
所以可以运用的场景有很多很多,例如,CSDN里的每一篇博文底下都有 评论与回复,可以看做是 写入操作,它是不频繁;但是,读取操作,也就是 浏览,是非常频繁的,这种类型的应用场景可以使用ReadWriteLock读/写锁
最后的最后,为了更好的阅读体验,我把想说的话都放在了下面,嘿嘿。
我是一颗剽悍的种子 把我会的,认真的分享 是我写博客一直不变的信条。
如果你能看到这篇博文,说明咱们还是很有缘的;希望能带给你一些许帮助,创作的不易, 把我文章的知识带走,你的三连留下,点赞,评论,关注,是我最大的动力。
文章浏览阅读1k次。通过使用ajax方法跨域请求是浏览器所不允许的,浏览器出于安全考虑是禁止的。警告信息如下:不过jQuery对跨域问题也有解决方案,使用jsonp的方式解决,方法如下:$.ajax({ async:false, url: 'http://www.mysite.com/demo.do', // 跨域URL ty..._nginx不停的xhr
文章浏览阅读2k次。关于在 Oracle 中配置 extproc 以访问 ST_Geometry,也就是我们所说的 使用空间SQL 的方法,官方文档链接如下。http://desktop.arcgis.com/zh-cn/arcmap/latest/manage-data/gdbs-in-oracle/configure-oracle-extproc.htm其实简单总结一下,主要就分为以下几个步骤。..._extproc
文章浏览阅读1.5w次。linux下没有上面的两个函数,需要使用函数 mbstowcs和wcstombsmbstowcs将多字节编码转换为宽字节编码wcstombs将宽字节编码转换为多字节编码这两个函数,转换过程中受到系统编码类型的影响,需要通过设置来设定转换前和转换后的编码类型。通过函数setlocale进行系统编码的设置。linux下输入命名locale -a查看系统支持的编码_linux c++ gbk->utf8
文章浏览阅读750次。今天准备从生产库向测试库进行数据导入,结果在imp导入的时候遇到“ IMP-00009:导出文件异常结束” 错误,google一下,发现可能有如下原因导致imp的数据太大,没有写buffer和commit两个数据库字符集不同从低版本exp的dmp文件,向高版本imp导出的dmp文件出错传输dmp文件时,文件损坏解决办法:imp时指定..._imp-00009导出文件异常结束
文章浏览阅读143次。当下是一个大数据的时代,各个行业都离不开数据的支持。因此,网络爬虫就应运而生。网络爬虫当下最为火热的是Python,Python开发爬虫相对简单,而且功能库相当完善,力压众多开发语言。本次教程我们爬取前程无忧的招聘信息来分析Python程序员需要掌握那些编程技术。首先在谷歌浏览器打开前程无忧的首页,按F12打开浏览器的开发者工具。浏览器开发者工具是用于捕捉网站的请求信息,通过分析请求信息可以了解请..._初级python程序员能力要求
文章浏览阅读7.6k次,点赞2次,收藏6次。@Service标注的bean,类名:ABDemoService查看源码后发现,原来是经过一个特殊处理:当类的名字是以两个或以上的大写字母开头的话,bean的名字会与类名保持一致public class AnnotationBeanNameGenerator implements BeanNameGenerator { private static final String C..._@service beanname
文章浏览阅读6.9w次,点赞73次,收藏463次。1.前序创建#include<stdio.h>#include<string.h>#include<stdlib.h>#include<malloc.h>#include<iostream>#include<stack>#include<queue>using namespace std;typed_二叉树的建立
文章浏览阅读7.1k次。在Asp.net上使用Excel导出功能,如果文件名出现中文,便会以乱码视之。 解决方法: fileName = HttpUtility.UrlEncode(fileName, System.Text.Encoding.UTF8);_asp.net utf8 导出中文字符乱码
文章浏览阅读2.1k次,点赞4次,收藏23次。第一次实验 词法分析实验报告设计思想词法分析的主要任务是根据文法的词汇表以及对应约定的编码进行一定的识别,找出文件中所有的合法的单词,并给出一定的信息作为最后的结果,用于后续语法分析程序的使用;本实验针对 PL/0 语言 的文法、词汇表编写一个词法分析程序,对于每个单词根据词汇表输出: (单词种类, 单词的值) 二元对。词汇表:种别编码单词符号助记符0beginb..._对pl/0作以下修改扩充。增加单词
文章浏览阅读773次。我在使用adb.exe时遇到了麻烦.我想使用与bash相同的adb.exe shell提示符,所以我决定更改默认的bash二进制文件(当然二进制文件是交叉编译的,一切都很完美)更改bash二进制文件遵循以下顺序> adb remount> adb push bash / system / bin /> adb shell> cd / system / bin> chm..._adb shell mv 权限
文章浏览阅读6.8k次,点赞12次,收藏125次。1. 单目相机标定引言相机标定已经研究多年,标定的算法可以分为基于摄影测量的标定和自标定。其中,应用最为广泛的还是张正友标定法。这是一种简单灵活、高鲁棒性、低成本的相机标定算法。仅需要一台相机和一块平面标定板构建相机标定系统,在标定过程中,相机拍摄多个角度下(至少两个角度,推荐10~20个角度)的标定板图像(相机和标定板都可以移动),即可对相机的内外参数进行标定。下面介绍张氏标定法(以下也这么称呼)的原理。原理相机模型和单应矩阵相机标定,就是对相机的内外参数进行计算的过程,从而得到物体到图像的投影_相机-投影仪标定
文章浏览阅读2.2k次。文章目录Wayland 架构Wayland 渲染Wayland的 硬件支持简 述: 翻译一篇关于和 wayland 有关的技术文章, 其英文标题为Wayland Architecture .Wayland 架构若是想要更好的理解 Wayland 架构及其与 X (X11 or X Window System) 结构;一种很好的方法是将事件从输入设备就开始跟踪, 查看期间所有的屏幕上出现的变化。这就是我们现在对 X 的理解。 内核是从一个输入设备中获取一个事件,并通过 evdev 输入_wayland