07-传统的生产者消费者问题、防止虚假唤醒

07-传统的生产者消费者问题、防止虚假唤醒

锁是什么，如何判断锁的是谁？

4、生产者和消费者问题

Synchronized 版本 wait 和 notify可以实现
JUC 版本 lock

生产者和消费者问题 Synchronized 版本

package com.hkx.pc;

/** * @program: juc * @description: A类 * @author: Casey Hu * @create: 2022-07-31 19:05 **/


/** * 线程之间的通讯问题：生产者和消费者问题 * 线程交替执行 A 线程 B线程 操作同一个变量 num=0 * 在A线程执行num加一的操作 * B线程之后执行num减一的操作 * 解决：使用通知唤醒，等待唤醒 */
public class A {
    
    public static void main(String[] args) {
    
        Data data = new Data();
        new Thread(()->{
    
            for (int i=0;i<10;i++){
    
                try {
    
                    data.increment();
                } catch (InterruptedException e) {
    
                    throw new RuntimeException(e);
                }
            }
        },"A").start();
        new Thread(()->{
    
            for (int i=0;i<10;i++){
    
                try {
    
                    data.decrement();
                } catch (InterruptedException e) {
    
                    throw new RuntimeException(e);
                }
            }
        },"B").start();

    }
}
/** * @Description: 资源类 * @Param: * @return: * @Author: Casey Hu * @Date: 2022/7/31 */
//判断等待，业务，通知
class Data{
    
    private int number=0;

    //加一操作
    public synchronized void increment() throws InterruptedException {
    
        if (number!=0){
    
           this.wait(); //等待操作
        }
        number++;
        System.out.println(Thread.currentThread().getName()+"=>"+number);
        //通知其他线程，完成了加一操作
        this.notifyAll();
    }
    //减一操作
    public synchronized void decrement() throws InterruptedException {
    
        if (number==0){
    
            this.wait();
        }
        number--;
        System.out.println(Thread.currentThread().getName()+"=>"+number);
        //通知其他线程，完成了减一操作
        this.notifyAll();
    }
}

问题存在，A B C D 4个线程 虚假唤醒

要把if 判断改成 while 判断

package com.hkx.pc;

/** * @program: juc * @description: A类 * @author: Casey Hu * @create: 2022-07-31 19:05 **/


/** * 线程之间的通讯问题：生产者和消费者问题 * 线程交替执行 A 线程 B线程 操作同一个变量 num=0 * 在A线程执行num加一的操作 * B线程之后执行num减一的操作 * 解决：使用通知唤醒，等待唤醒 */
public class A {
    
    public static void main(String[] args) {
    
        Data data = new Data();
        new Thread(()->{
    
            for (int i=0;i<10;i++){
    
                try {
    
                    data.increment();
                } catch (InterruptedException e) {
    
                    throw new RuntimeException(e);
                }
            }
        },"A").start();
        new Thread(()->{
    
            for (int i=0;i<10;i++){
    
                try {
    
                    data.decrement();
                } catch (InterruptedException e) {
    
                    throw new RuntimeException(e);
                }
            }
        },"B").start();
        new Thread(()->{
    
            for (int i=0;i<10;i++){
    
                try {
    
                    data.decrement();
                } catch (InterruptedException e) {
    
                    throw new RuntimeException(e);
                }
            }
        },"C").start();
        new Thread(()->{
    
            for (int i=0;i<10;i++){
    
                try {
    
                    data.decrement();
                } catch (InterruptedException e) {
    
                    throw new RuntimeException(e);
                }
            }
        },"D").start();
    }
}
/** * @Description: 资源类 * @Param: * @return: * @Author: Casey Hu * @Date: 2022/7/31 */
//判断等待，业务，通知
class Data{
    
    private int number=0;

    //加一操作
    public synchronized void increment() throws InterruptedException {
    
        while (number!=0){
    
           this.wait(); //等待操作
        }
        number++;
        System.out.println(Thread.currentThread().getName()+"=>"+number);
        //通知其他线程，完成了加一操作
        this.notifyAll();
    }
    //减一操作
    public synchronized void decrement() throws InterruptedException {
    
        while (number==0){
    
            this.wait();
        }
        number--;
        System.out.println(Thread.currentThread().getName()+"=>"+number);
        //通知其他线程，完成了减一操作
        this.notifyAll();
    }
}