使用信号灯法，标志位解决测试生产者消费者问题（源码解析、建议收藏）

小灰灰 2023-10-04 16:17 17阅读 0赞

### 测试生产者消费者问题2-信号灯法，标志位解决（Java） ###

package src.thread;
    
    //测试生产者消费者问题2：信号灯法，标志位解决
    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 {
        
        TV tv;
    
        public Player(TV tv) {
          //构造方法
            this.tv = tv;
    
        }
    
        @Override
        public void run() {
        
            for (int i = 0; i < 20; i++) {
        
                if (i % 2 == 0) {
        
                    this.tv.play("快乐大本营播放中");
                } else {
        
                    this.tv.play("抖音：记录美好生活");//广告
                }
            }
        }
    }
    
    
    //消费者-->观众
    class Watcher extends Thread {
        
        TV tv;
    
        public Watcher(TV tv) {
          //构造方法
            this.tv = tv;
        }
    
        @Override
        public void run() {
        
            for (int i = 0; i < 20; i++) {
        
                tv.watch();
            }
        }
    }
    
    //产品-->节目
    class TV {
        
        //演员表演，观众等待  True
        //观众观看，演员等待   False
        String voice;//表演的节目
        boolean flag = true;//设置标志位，判断演员是否表演
    
        //表演
        public synchronized void play(String voice) {
        
            if (!flag) {
         //若观众观看的时候，演员需等待
                try {
        
                    this.wait();
                } catch (InterruptedException e) {
        
                    e.printStackTrace();
                }
            }
            System.out.println("演员表演了：" + voice);
            //通知观众观看
            this.notifyAll();//通知（唤醒）
            this.voice = voice;
            this.flag = !this.flag;
    
        }
    
        //观看
        public synchronized void watch() {
        
            if (flag) {
          //若演员表演的时候。观众需等待
                try {
        
                    this.wait();
                } catch (InterruptedException e) {
        
                    e.printStackTrace();
                }
            }
            System.out.println("观众观看了：" + voice);
    
            //观众观看完通知演员表演
            this.notifyAll();
            this.flag = !this.flag;
        }
    }