1. package com.pln.gaoji;
    2. //测试生产者消费者问题2：信号灯法，标志位解决
    3. public class TestPC2 {
    4.     public static void main(String[] args) {
    5.         TV tv = new TV();
    6.         new Player(tv).start();
    7.         new Watcher(tv).start();
    8.     }
    9. }
    10. //生产者--》演员
    11. class Player extends Thread{
    12.     TV tv;
    13.     public Player(TV tv){
    14.         this.tv = tv;
    15.     }
    17.     @Override
    18.     public void run() {
    19.         for (int i = 0; i < 20; i++) {
    20.             if(i%2==0){
    21.                 try {
    22.                     this.tv.play("快了大本营");
    23.                 } catch (InterruptedException e) {
    24.                     e.printStackTrace();
    25.                 }
    26.             }else{
    27.                 try {
    28.                     this.tv.play("抖音美好生活");
    29.                 } catch (InterruptedException e) {
    30.                     e.printStackTrace();
    31.                 }
    32.             }
    33.         }
    34.     }
    35. }
    36. //消费者--》观众
    37. class Watcher extends Thread{
    38.     TV tv;
    39.     public Watcher(TV tv){
    40.         this.tv = tv;
    41.     }
    43.     @Override
    44.     public void run() {
    45.         for (int i = 0; i < 20; i++) {
    46.             try {
    47.                 this.tv.watch();
    48.             } catch (InterruptedException e) {
    49.                 e.printStackTrace();
    50.             }
    51.         }
    52.     }
    53. }
    54. //产品--》节目
    55. class TV{
    56.     //演员表演，观众等待 T
    57.     //观众观看，演员等待 F
    58.     String voice;
    59.     boolean flag = true;
    60.     //表演
    61.     public synchronized void play(String voice) throws InterruptedException {
    62.         if(!flag){
    63.             this.wait();//表演等待一会
    64.         }
    65.         System.out.println("演员表演了"+voice);
    66.         //通知观众看表演
    67.         this.notifyAll();
    68.         this.voice = voice;
    69.         this.flag = !this.flag;
    71.     }
    72.     //观众观看
    73.     public synchronized void watch() throws InterruptedException {
    74.         if(flag){
    75.             this.wait();
    76.         }
    77.         //通知演员表演
    78.         System.out.println("观众观看了"+voice);
    79.         //通知演员表演
    80.         this.notifyAll();
    81.         this.flag = !this.flag;
    82.     }
    83. }

    image.png