版权声明:尊重原创,码字不易,转载需博主同意。 https://blog.csdn.net/qq_34626097/article/details/88930706
文章目录
为什么会产生虚假唤醒?
- Object.wait()当我们运行到这个方法的时候,当前线程会进入等待状态,并释放锁,而当其他线程去唤醒它的时候,它会之后wait()的地方继续开始执行。
- Object.notifyAll() 会唤醒所有处于等待状态的线程抢夺线程锁,所以两个线程会重新抢锁。
- 当只有单个生产者和单个消费者的时候和 使用 if - else,产生虚假唤醒是因为 当product = 1的时候,生产者抢到锁,然后自己wait并释放资源,消费者抢到资源,并把product = 0,然后唤醒生产者,然后抢锁,然后生产者抢到锁并执行完毕,没有运行 else 里面的notifyAll(),之后就只剩下消费者,其拿到锁之后,product = 0, 并wait了。
- 没有使用 else 的情况下,当单个生产者和单个消费者不会产生问题,但多个的时候还时会有线程问题。
- 多个生产者和多个消费者,且没有使用 else 的情况下,只要两个消费者或两个生产者先后抢到锁,就会出现线程问题。因为wait()被唤醒之后是从wait()的地方开始执行的。
解决方案
- 其实在API中已经为提供了解决方案
- 他的意思就是说:如果是需要使用Object.wait(),避免发生虚假唤醒的方法就是将其放在while(进入线程等待的条件){ Object.wait() } , 其就是当我线程被唤醒的时候,也是需要再进行一次判断的。
- 解决之后的结果
/*
*虚假唤醒
*/
public class TestProductorAndConsumer {
public static void main(String[] args) {
Clerk clerk = new Clerk();
Productor pro = new Productor(clerk);
Consumer cus = new Consumer(clerk);
new Thread(pro,"生产者A").start();
new Thread(pro,"生产者D").start();
new Thread(cus,"消费者C").start();
new Thread(cus,"消费者F").start();
}
}
//销售员
class Clerk{
private int product = 0 ;
//进货
public synchronized void get() {
while(product >= 1) {//为了解决虚假唤醒问题,应该总是使用在循环中
System.out.println("产品已经满了");
try {
this.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
// else {
System.out.println(Thread.currentThread().getName()+ " : " + ++product);
this.notifyAll();
// }
}
//出售
public synchronized void sale() {
while(product <= 0) {
System.out.println("缺货");
try {
this.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
// else {
System.out.println(Thread.currentThread().getName() + " : " + --product);
this.notifyAll();
// }
}
}
//生产者
class Productor implements Runnable{
private Clerk clerk;
public Productor(Clerk clerk) {
super();
this.clerk = clerk;
}
@Override
public void run() {
for (int i = 0; i < 20; i++) {
clerk.get();
}
}
}
//消费者
class Consumer implements Runnable {
private Clerk clerk;
public Consumer(Clerk clerk) {
super();
this.clerk = clerk;
}
@Override
public void run() {
for (int i = 0; i < 20; i++) {
try {
Thread.sleep(200);
} catch (InterruptedException e) {
e.printStackTrace();
}
clerk.sale();
}
}
}