栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

java多线程-- 生产者消费者

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

java多线程-- 生产者消费者

生产者消费者问题 编程模型:

有一家店,有很多人来,为了提升顾客体验,前台可以放10份餐,不足10份后厨就会通知后厨补上,如果到10份就停止生产.,只要前台有餐就通知顾客取餐,没有餐让顾客等待.

代码有问题,希望大佬指点下 (已找到, 把else去掉就好了)

进程会一直卡在这里

package cn.usts.edu.lesson08;

import cn.usts.util.Utils;




public class ProductorConsumerDemo {
    public static void main(String[] args) {
        Container1 container = new Container1();
        Productor productor = new Productor(container);
        Consumer consumer = new Consumer(container);
        productor.start();
        consumer.start();
    }


}

// 生产者
class Productor extends Thread{
    Container1 container;

    public Productor(Container1 container) {
        this.container = container;
    }

    @Override
    public void run() {
        // 生产100只鸡
        for (int i = 0; i < 100; i++) {
            container.push(new Chicken(i));
            System.out.println("生产了第"+i+"只鸡");
        }
    }
}

// 消费者
class Consumer extends Thread{
    Container1 container;

    public Consumer(Container1 container) {
        this.container = container;
    }

    @Override
    public void run() {
        // 消费100只鸡
        for (int i = 0; i < 100; i++) {
            Chicken chicken = container.pop();
            System.out.println("消费了第--------"+chicken.id+"只鸡");
        }
    }
}


// 生产的产品
class Chicken{
    int id;// 产品编号

    public Chicken(int id) {
        this.id = id;
    }
}


// 容器 缓冲
class Container1 extends Utils {

    // 容器
    Chicken[]  chickens = new Chicken[10];//默认可以放10只鸡

    int count=0;//用来计数
    int index=1;

    // 把鸡放到容器中
    public synchronized void push(Chicken chicken){
        // 如果数量达到容器的最大数量,停止生产
        if (chickens.length==count){
            try {
                System.out.println(count+"---------------------");
                this.wait();// 容器满了通知生产者等待
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        // 如果没有达到容器数量,就生产
        
            chickens[count] = chicken;//把鸡放到容器中
            count++;//容器数量加1

            this.notifyAll();//全都唤醒
        
    }

    // 消费者消费鸡
    public synchronized Chicken pop(){
        // 判断容器中有么有鸡
        if (count==0){
            try {
                this.wait(); // 通知消费者等待
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
        // 有鸡
        count--;
        Chicken chicken = chickens[count]; // 有bug
        this.notify();//通知消费者消费
        return chicken;



    }

}





转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/351464.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号