水能zai舟 2021-05-21 10:44 采纳率: 50%
浏览 69

以下代码产生死锁的原因是什么?

以下是一个生产者与消费者的DEMO,但是运行过程中出现死锁,请问原因是什么?

Production类:

@Data
public class Production {

    private int id;

    private boolean flag;

    public Production() {
        id = 0;
        flag = false;
    }
    
}

 

生产者类:

public class Productor {

    private Production production;

    public Productor(Production production) {
        this.production = production;
    }

    public synchronized void product() {
        if (!production.isFlag()) {

            production.setId(production.getId() + 1);
            System.out.println(Thread.currentThread().getName() + "product第: " + production.getId());

            production.setFlag(!production.isFlag());
            notifyAll();
        } else {
            try {
                wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}


消费者类:

public class Consumer {
    private Production production;

    public Consumer(Production production) {
        this.production = production;
    }

    public synchronized void consume() {

        if (production.isFlag()) {

            System.out.println(Thread.currentThread().getName() + "consume第: " + production.getId());

            production.setFlag(!production.isFlag());
            notifyAll();
        } else {
            try {
                wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

    }
}

 

跑起来:
 

public class ThreadTest {

    public static void main(String[] args) {

        Production production = new Production();
        Productor productor = new Productor(production);
        Consumer consumer = new Consumer(production);

        new Thread(() -> {
            for (int i = 0; i < 100; i ++ ) productor.product();
        }).start();

        new Thread(() -> {
            for (int i = 0; i < 100; i ++ ) consumer.consume();
        }).start();
   }

 

结果:

Thread-0product第: 1
Thread-1consume第: 1



...没有下文了
  • 写回答

1条回答 默认 最新

  • benbenli 2021-05-21 11:18
    关注

    生产者消费者的synchronized函数互相并没有互斥操作production的作用。生产者和消费者的函数都不加synchronized,二改为都 synchronized(production) 吧。

    另外 Boolean类型的读写不一定是原子操作,不宜作为进入互斥的方法。synchronized(production)可以。

     

     

    评论

报告相同问题?

悬赏问题

  • ¥15 如何让企业微信机器人实现消息汇总整合
  • ¥50 关于#ui#的问题:做yolov8的ui界面出现的问题
  • ¥15 如何用Python爬取各高校教师公开的教育和工作经历
  • ¥15 TLE9879QXA40 电机驱动
  • ¥20 对于工程问题的非线性数学模型进行线性化
  • ¥15 Mirare PLUS 进行密钥认证?(详解)
  • ¥15 物体双站RCS和其组成阵列后的双站RCS关系验证
  • ¥20 想用ollama做一个自己的AI数据库
  • ¥15 关于qualoth编辑及缝合服装领子的问题解决方案探寻
  • ¥15 请问怎么才能复现这样的图呀