[转载]Java8并发教程-Synchronization and Locks

原文:Java8并发教程-Synchronization and Locks

这是该系列教程的第二篇.其中用到了一个工具类,和其中的两个方法.如下图所示:

image.png

1 Synchronized

在第一篇教程中,我们已经介绍了如何通过** Executor Service**来并行执行任务.但是,这也引入了一个新的问题.即我们如何并发的访问那些共享的变量.假设我们打算用多个线程来并发地增加一个数字.我们使用下面的代码:

image.png
image.png

我们可以看到,其结果不是正确的结果,即10000.那为什么会出现这种情况呢?这是因为我们不恰当的让多个线程并发的访问并设置共享变量而造成的.本例中,共享变量即为count.

当执行一个加法操作时,需要按三步进行:
1.读取当前值
2.使当前值加一
3.将这个新值写入到变量中.
如果有两个线程同时执行第一步,即读取当前值,它们获得了相同的值,就会造成写丢失.也就是说,第二个线程在执行第三步时,会覆盖掉第一个进程写入的结果.

Java中,我们可以通过使用synchronized关键字,来防止这种情况的出现.

我们使用synchronized关键字来改写上面的执行加法操作的函数:

image.png

现在我们让线程通过执行这个函数来并发地进行加法操作:

image.png

现在我们可以看到,结果是正确的.不管你执行多少次,结果都是正确的.

synchronized关键字,不仅可以用在函数上,还可以用在代码块中:

image.png

synchronized关键字的内部, Java使用一个叫做monitor的东西来管理它,monitor也被称作monitor lock 或 intrinsic lock. monitor是和对象关联在一起的,每个synchronized的方法,针对一个对象,都使用同一个monitor.

synchronized也有可重入的特性,也就是说,即使当前线程已经占有了锁,它还是可以请求相同的锁的,这就避免了死锁的产生.

2 Locks

除了通过使用synchronized这种隐式锁来进行同步,Concurrency API中,还提供了大量显式锁.通过使用这些显式锁,我们能对并发进行更好的控制.

下面我们会一个个的介绍这些显式锁.

3 ReentrantLock

这个锁是一个互斥锁.它也实现了** synchronized**中的隐式锁的基本特性,当然,它还是有一些自己的特性的.这个锁也是可重入的.

我们使用ReentrantLock来实现上面的例子:

image.png

我们通过lock()方法来获得锁,而通过unlock()方法,来释放锁.我们要用try/catch来包装我们的代码,来防止锁得不到释放.这个函数也是线程安全的.如果其他线程在这个锁没有释放之前,想要获得锁,就会被阻塞.只有一个线程能够同时占有锁.

除此之外,锁还提供了其他的函数,如下图所示:

image.png

第一个任务获得锁,然后暂停一秒钟.而第二个任务则获取锁的当前状态,并将其输出出来.

image.png

tryLock()会尝试获取锁,而不会像lock()方法一样,阻塞线程.我们需要在执行那些需要访问共享变量的操作之前,检查一下其返回值,以防止不同步的情况.

4 ReadWriteLock

ReadWriteLock包含一对锁,分别用于对共享变量的读和写操作.ReadWriteLock背后的原理是,如果当前没有线程来修改共享变量,那么允许多个线程来访问共享变量,而没有什么危险.所以说,当没有线程持有写锁的时候,可以有多个线程持有读锁.这在那些读操作远大于写操作的场景中,极大的提高了性能和吞吐量.

image.png
image.png

在你执行上面的代码时,你会注意到,只有当写锁被释放之后,后面的线程才会同时获取到读锁.而不需要等第一个线程的读锁释放之后,第二个线程才能获取读锁.

5 StampedLock

Java8中,还增加了一种叫做StampedLock的锁,这个锁也有读锁和写锁,就跟上面的ReadWriteLock一样.但是,和ReadWriteLock不同,它会返回一个long类型的值,我们可以通过这个值来释放锁,检查锁是否有效.另外,它还包含一种叫做乐观锁的锁.

我们有下面的代码:

image.png

我们通过readLock()方法来获取读锁,通过writeLock()方法来获取写锁.需要注意的是,StampedLock并没有可重入的特性.如果没有锁可用,则调用上面的方法,会导致返回一个值,并阻塞线程,即使当前线程已经有锁了.所以你使用这个锁的时候,要小心,别出现死锁的情况.

ReadWriteLock锁一样,要获得读锁,必须等待写锁被释放.

我们使用下面的这个例子,来了解乐观锁:

image.png

tryOptimisticRead()方法,会获得一个乐观读锁.它总会返回一个值,而不会阻塞当前线程.如果有线程持有写锁,则返回值是0.所以,我们需要通过lock.validate()方法来检查一下返回值,来确定是否真的有读锁可用.

上面的代码,输出如下:

image.png

我们应当在获取到乐观锁之后,就立即使用它.因为它随时可能无效.与平常的读锁不同,乐观锁不会阻止其他的线程获得写锁.也就是说,在一个线程占有乐观锁的时候,其他的线程还是可以获取到写锁的,而不需要等待乐观锁被释放.当其他线程获得了写锁之后,乐观锁就失效了.即使那个线程后来又释放了写锁.

所以,如果使用乐观锁的话,我们需要时刻验证乐观锁是否还有效.特别是在执行对共享变量的写操作之前.

有时,我们需要将一个读锁转换成写锁.StampedLock提供了tryConvertToWriteLock()这个方法,来进行转换.

image.png

上面的那个任务,会先获取读锁,并尝试输出count变量的值.但是当其等于0时,它会将读锁转换成写锁,如果转换成功,则将23赋给count.如果不成功,则直接通过lock.writeLock()来以阻塞的方式获取写锁.然后将23赋给count.最后,再释放锁.

6 Semaphores

除了锁,Concurrency API也支持信号量.锁通常用于互斥的访问某些资源,而信号量用于限制一定的线程可以同时访问某些资源.

下面这个例子,演示了如何使用信号量:

image.png

Executor允许同时执行十个线程,但是因为我们将信号量设置成了5.所以实际上,只有5个线程有机会来执行操作.

输出如下:

image.png

只有前五个线程,能够获得一个信号量,然后来执行暂停五分钟的操作.其他的线程,因为没有信号量可以获取了,就只能在控制台打印处Could not acquire semaphore.

作者:AlstonWilliams
链接:https://www.jianshu.com/p/053150087cd5
來源:简书
简书著作权归作者所有,任何形式的转载都请联系作者获得授权并注明出处。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 201,681评论 5 474
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 84,710评论 2 377
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 148,623评论 0 334
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,202评论 1 272
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,232评论 5 363
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,368评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 37,795评论 3 393
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,461评论 0 256
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 40,647评论 1 295
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,476评论 2 317
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,525评论 1 329
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,226评论 3 318
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 38,785评论 3 303
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,857评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,090评论 1 258
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 42,647评论 2 348
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,215评论 2 341

推荐阅读更多精彩内容

  • 1.解决信号量丢失和假唤醒 public class MyWaitNotify3{ MonitorObject m...
    Q罗阅读 864评论 0 1
  • 这是该系列教程的第二篇.其中用到了一个工具类,和其中的两个方法.如下图所示: Synchronized 在第一篇教...
    AlstonWilliams阅读 353评论 0 1
  • 一、前言 借用Java并发编程实践中的话"编写正确的程序并不容易,而编写正常的并发程序就更难了",相比于顺序执行的...
    运维开发笔记阅读 329评论 0 2
  • 今早到公司,所有人都在讨论地震的事情。“我感觉到晃动就马上穿衣服了,等到5点多也没地震,后来就起来做饭了”这是我们...
    烟花雨荨阅读 243评论 0 1
  • 001、愤怒就是把当下的情绪和以前的记忆区混为一谈 朋友小C是个大专生,有梦想敢追寻,有意中人敢追求,典型热情豪放...
    玉儿说阅读 200评论 0 1