专栏名称: 朱小厮的博客
著有畅销书:《深入理解Kafka》和《RabbitMQ实战指南》。公众号主要用来分享Java技术栈、Golang技术栈、消息中间件(如Kafka、RabbitMQ)、存储、大数据以及通用型技术架构等相关的技术。
目录
相关文章推荐
植物星球  ·  檫木终于开启了这个春天 ·  4 天前  
新华每日电讯  ·  中国最北、又冷又偏的小城漠河,如今“不等闲” ·  3 天前  
新华每日电讯  ·  中国最北、又冷又偏的小城漠河,如今“不等闲” ·  3 天前  
51好读  ›  专栏  ›  朱小厮的博客

阿里面试题,为什么wait()方法要放在同步块中?

朱小厮的博客  · 公众号  ·  · 2019-11-27 08:41

正文

点击上方“ 朱小厮的博客 ”,选择“ 设为星标

后台回复” 加群 “加入公众号专属技术群



某天我在***的时候,突然有个小伙伴微信上说:“哥,阿里面试又又挂了,被问到为什么wait()方法要放在同步块中,没答出来!”

我顿时觉得**一紧,仔细回顾一下,如果wait()方法不在同步块中,代码的确会抛出异常:

  1. public class WaitInSyncBlockTest {


  2. @Test

  3. public void test() {

  4. try {

  5. new Object().wait();

  6. } catch (InterruptedException e) {

  7. e.printStackTrace();

  8. }

  9. }

  10. }

结果是:

但是,为毛呢??我也没去了解过。

机智如我立刻假装正在开会忙得不可开交,回了一条:“开会中,等会和你细说。”

经过一番谷歌之后,找到了答案。

Lost Wake-Up Problem

事情得从一个多线程编程里面臭名昭著的问题"Lost wake-up problem"说起。

这个问题并不是说只在Java语言中会出现,而是会在所有的多线程环境下出现。

假如有两个线程,一个消费者线程,一个生产者线程。生产者线程的任务可以简化成将count加一,而后唤醒消费者;消费者则是将count减一,而后在减到0的时候陷入睡眠:

生产者伪代码:

  1. count+1;

  2. notify();

消费者伪代码:

  1. while(count<=0)

  2. wait()


  3. count--

熟悉多线程的朋友一眼就能够看出来,这里面有问题。什么问题呢?

生产者是两个步骤:

  1. count+1;

  2. notify();

消费者也是两个步骤:

  1. 检查count值;

  2. 睡眠或者减一;

万一这些步骤混杂在一起呢?比如说,初始的时候count等于0,这个时候消费者检查count的值,发现count小于等于0的条件成立;就在这个时候,发生了上下文切换,生产者进来了,噼噼啪啪一顿操作,把两个步骤都执行完了,也就是发出了通知,准备唤醒一个线程。这个时候消费者刚决定睡觉,还没睡呢,所以这个通知就会被丢掉。紧接着,消费者就睡过去了……

这就是所谓的lost wake up问题。

那么怎么解决这个问题呢?

现在我们应该就能够看到,问题的根源在于,消费者在检查count到调用wait()之间,count就可能被改掉了。

这就是一种很常见的竞态条件。

很自然的想法是,让消费者和生产者竞争一把锁,竞争到了的,才能够修改count的值。

于是生产者的代码是:

  1. tryLock()


  2. count+1


  3. notify()


  4. releaseLock()

消费者的代码是:

  1. tryLock()


  2. while(count <= 0)

  3. wait()


  4. count-1


  5. releaseLock

注意的是,我这里将两者的两个操作都放进去了同步块中。

现在来思考一个问题,生产者代码这样修改行不行?

  1. tryLock()


  2. count+1


  3. notify()


  4. releaseLock()

答案是,这样改毫无卵用,依旧会出现lost wake up问题,而且和无锁的表现是一样的。

终极答案

所以,我们可以总结到,为了避免出现这种lost wake up问题,在这种模型之下,总应该将我们的代码放进去的同步块中。

Java强制我们的wait()/notify()调用必须要在一个同步块中,就是不想让我们在不经意间出现这种lost wake up问题。

不仅仅是这两个方法,包括java.util.concurrent.locks.Condition的await()/signal()也必须要在同步块中:

  1. private ReentrantLock lock = new ReentrantLock();


  2. private Condition condition = lock.newCondition();


  3. @Test

  4. public void test() {

  5. try {

  6. condition.signal();

  7. } catch (Exception e) {

  8. e.printStackTrace();

  9. }

  10. }

准确的来说,即便是我们自己在实现自己的锁机制的时候,也应该要确保类似于wait()和notify()这种调用,要在同步块内,防止使用者出现lost wake up问题。

Java的这种检测是很严格的。它要求的是,一定要处于锁对象的同步块中。举例来说:

  1. private Object obj = new Object();








请到「今天看啥」查看全文