标签：消费者 生产者 void class 问题 tv num public synContainer

生产者与消费者问题

1. 管程法-利用缓冲区解决
2. 信号灯法-利用标志位解决

管程法

package com.edgar.gaoji;

//测试：生产者与消费者模型-->利用缓冲区解决-管程法
public class TestPC {

    public static void main(String[] args) {
        SynContainer synContainer = new SynContainer();
        new Productor(synContainer).start();
        new Customer(synContainer).start();

    }

}

//生产者
class Productor extends Thread{
    SynContainer synContainer;

    public Productor(SynContainer synContainer) {
        this.synContainer = synContainer;
    }

    @Override
    public void run() {
        for (int i = 1; i <=100; i++) {

            try {
                synContainer.push(new Chicken(i));
                System.out.println("生产了"+i+"只鸡");
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

//消费者
class Customer extends Thread{
    SynContainer synContainer;

    public Customer(SynContainer
                            synContainer) {
        this.synContainer = synContainer;
    }

    @Override
    public void run() {
        for (int i = 1; i <=100; i++) {
            try {
                System.out.println("消费了-->"+synContainer.take().id+"只鸡");
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}

//产品
class Chicken{
    int id;

    public Chicken(int id) {
        this.id = id;
    }
}
//缓冲区
class SynContainer {

    //需要一个容器大小
    Chicken[] chickens= new Chicken[10];
    //容器计数器
    int num=0;

    //生产者放入产品
    public synchronized void push(Chicken chicken) throws InterruptedException {
        //如果容器满了，就需要等待消费
        if(num==chickens.length){
            wait();
        }
        //如果没有满，继续丢入产品
            chickens[num]=chicken;
            num++;
            //唤醒消费者去消费
            this.notifyAll();
    }

    //消费者消费产品
    public synchronized Chicken take() throws InterruptedException {
        //如果容器为空，等待生产
        if(num==0){
            wait();
        }

        //如果没有空，取出产品
        num--;
        Chicken chicken=chickens[num];
        //唤醒生产者去生产
        this.notifyAll();
        return chicken;
    }


}

信号灯法

package com.edgar.gaoji;
//测试：生产者与消费者模型-->利用标志位解决-信号灯法
public class TestPC2 {
    public static void main(String[] args) {
        TV tv = new TV();
        new Player(tv).start();
        new Watcher(tv).start();

    }
}

//生产者-->演员
class Player extends Thread {
    private TV tv;

    public Player(TV tv){
        this.tv=tv;
    }


    @Override
    public void run() {
        for (int i = 0; i < 24; i++) {
            if(i%2==0){
                tv.play("电视剧神话");
            }else{
                tv.play("广告");
            }

        }

    }
}

//消费者-->观众
class Watcher extends Thread {
    private TV tv;

    public Watcher(TV tv){
        this.tv=tv;
    }
    @Override
    public void run() {
        for (int i = 0; i < 24; i++) {
            tv.watch();
        }
    }
}

//产品-->节目
class TV {
    private String name;//表演的节目
    //演员表演，观众等待T
    //观众观看，演员等待F
    boolean flag=true;//标志位

    //表演
    public synchronized void play(String name) {
        if(!flag){
            try {
                wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

        System.out.println("演员表演了"+name);
        this.name=name;
        this.notifyAll();
        this.flag=!flag;

    }

    //观看
    public synchronized void watch() {
        if(flag){
            try {
                wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }

        System.out.println("观众观看了"+name);
        this.notifyAll();
        this.flag=!flag;

    }


}

标签：消费者,生产者,void,class,问题,tv,num,public,synContainer
来源： https://www.cnblogs.com/edgarstudy/p/14665287.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。