一直搞不懂Java线程通信，这次终于明白了( 二 ) _Java

运行结果：发现爸爸线程和妈妈线程连着做了三次饭

文章插图
原因：

这是由于wait方法的机制导致的，wait方法会使线程阻塞，直到被唤醒之后才会运行，在哪里阻塞，再次被唤醒之后得到CPU执行权，就会在哪里继续运行
现在是4条线程，假设爸爸线程运行之后将 hasFood 改为true，此时爸爸线程就会唤醒其他线程，也就是妈妈线程和小明，大明线程都会被唤醒，如果此时妈妈线程获取到CPU时间片开始运行，判断 hasFood 为 true，那么就触发wait等待，等待之后就会释放CPU执行权，唤醒其他线程
如果此时爸爸线程又获取到CPU执行权，同样判断hasFood之后为true，就会进入等待，唤醒其他线程，如果此时CPU执行权又分配给了妈妈线程，因为之前已经经过了判断，就会在wait的地方，继续执行，就会触发给娃做饭，之后再唤醒其他线程
此时爸爸线程得到CPU时间片，则会在上次wait的地方继续执行，同样的给娃做饭，就会出现上图的效果，爸妈线程交替做饭

文章插图
解决：将if替换为while，while语句块每次执行完之后都会重新判断，知道条件不成立才会结束循环，即可解决

public class KitChenRoom {private boolean hasFood = false;private Object lock = new Object();public void cook() {// 加锁synchronized (lock) {// 将if替换为whilewhile(hasFood) {// 还有吃的，先不做饭try {lock.wait();} catch (InterruptedException e) {throw new RuntimeException(e);}}// 否则就做饭，System.out.println(Thread.currentThread().getName() + "没吃的了，给娃做饭！");// 做好之后，修改为truehasFood = true;// 通知其他线程吃饭lock.notifyAll();}}// 吃饭public void eat() {synchronized (lock) {// 将if替换为whilewhile (!hasFood) {try {lock.wait();} catch (InterruptedException e) {throw new RuntimeException(e);}}// 否则就吃饭System.out.println(Thread.currentThread().getName() + "感谢老妈，恰饭，恰饭");// 吃完之后，修改为falsehasFood = false;// 通知其他线程吃饭lock.notifyAll();}}}

运行结果：发现做饭和吃饭交替执行

文章插图
为什么使用while就能解决呢？其实就是 if和while的区别
由于在多线程内容中，有很多小伙伴犯迷，为什么用while就解决了，其实是思路没有打开，把以前学的东西都忘记了，满脑子都是多线程的东西，你说是不是！学习要融会贯通，将前后所有的知识点串起来
解决虚假唤醒非常简单，其实就是利用了while的特性，while体每次执行都会循环再次判断条件，直到条件不成立跳出循环，在这也是一样：

妈妈线程执行发现hasFood = true，就进入等待，再次得到cpu时间片执行时，在哪里等待就在哪里醒来继续执行，也就是再lock.wait()的地方继续执行
由于该代码在while循环中，会循环判断，如果hasFood = true继续wait，如果hasFood = false就跳出循环，执行循环体之外的代码
但是如果是if，就只会判断一次，醒来之后不会再次判断，因为lock.wait()代码已经执行过了，会直接向下执行，开始给娃做饭

文章插图
notify和notifyAll上边我们使用notifyAll唤醒了所有线程，如果将notifyAll替换为notify会发生什么？

public class KitChenRoom {private boolean hasFood = false;private Object lock = new Object();public void cook() {synchronized (lock) {while (hasFood) {try {lock.wait();} catch (InterruptedException e) {throw new RuntimeException(e);}}System.out.println(Thread.currentThread().getName() + "没吃的了，给娃做饭！");hasFood = true;// // 替换为notifylock.notify();}}public void eat() {synchronized (lock) {while (!hasFood) {try {lock.wait();} catch (InterruptedException e) {throw new RuntimeException(e);}}hasFood = false;// 替换为notifylock.notify();}}}

运行结果：运行三次，发现前两次程序卡住不动，产生死锁，第三次正常执行完