java线程：生产者消费者模式(信号灯法)

骑猪看日落 2022-04-25 08:08 119阅读 0赞

# 组成 #

*  演员(Player)
 *  观众(Watcher)
 *  舞台(Stage)

# 演员 #

/**
     * 
     * @ClassName: Player
     * @Description:TODO(演员)
     * @author: 卫卫
     * @date: 2019年5月30日 下午5:00:06
     * 
     *        测试学习
     */
    class Player implements Runnable {
    
    	Stage stage;
    
    	public Player(Stage stage) {
    		this.stage = stage;
    	}
    
    	@Override
    	public void run() {
    		for (int i = 0; i < 10; i++) {
    			if (i % 2 == 0) {
    				stage.say("师傅被妖怪抓走了");
    			} else {
    				stage.say("妖怪哪里跑");
    			}
    		}
    	}
    }

# 观众 #

/**
     * 
     * @ClassName: Watcher
     * @Description:TODO(观众)
     * @author: 卫卫
     * @date: 2019年5月30日 下午5:00:31
     * 
     *        测试学习
     */
    class Watcher implements Runnable {
    
    	Stage stage;
    
    	public Watcher(Stage stage) {
    		this.stage = stage;
    	}
    
    	@Override
    	public void run() {
    		for (int i = 0; i < 10; i++) {
    			stage.watch();
    		}
    	}
    
    }

# 舞台 #

/**
     * 
     * @ClassName: Stage
     * @Description:TODO(舞台)
     * @author: 卫卫
     * @date: 2019年5月30日 下午5:00:43
     * 
     *        测试学习
     */
    class Stage {
    
    	String voice;
    
    	// 信号灯
    	boolean flag = true;
    
    	public synchronized void say(String voice) {
    		// 当为true时演员表演否则处于等待状态
    		if (!flag) {
    			try {
    				this.wait();
    			} catch (InterruptedException e) {
    				e.printStackTrace();
    			}
    		}
    		this.voice = voice;
    		flag = !flag;
    		this.notifyAll();
    		System.out.println("演员说：" + this.voice);
    	}
    
    	public synchronized void watch() {
    		// 当为false时观众听否则处于等待状态
    		if (flag) {
    			try {
    				this.wait();
    			} catch (InterruptedException e) {
    				e.printStackTrace();
    			}
    		}
    		flag = !flag;
    		this.notifyAll();
    		System.out.println("观众听到了：" + this.voice);
    	}
    }

# 测试 #

/**
     * 
     * @ClassName: Test8
     * @Description:TODO(消费者和生产者模式：信号灯法)
     * @author: 卫卫
     * @date: 2019年5月30日 下午5:00:22
     * 
     *        测试学习
     */
    public class Test8 {
    
    	public static void main(String[] args) {
    		Stage stage = new Stage();
    		new Thread(new Player(stage)).start();
    		new Thread(new Watcher(stage)).start();
    	}
    }

# 输出结果 #

演员说：师傅被妖怪抓走了
    观众听到了：师傅被妖怪抓走了
    演员说：妖怪哪里跑
    观众听到了：妖怪哪里跑
    演员说：师傅被妖怪抓走了
    观众听到了：师傅被妖怪抓走了
    演员说：妖怪哪里跑
    观众听到了：妖怪哪里跑
    演员说：师傅被妖怪抓走了
    观众听到了：师傅被妖怪抓走了
    演员说：妖怪哪里跑
    观众听到了：妖怪哪里跑
    演员说：师傅被妖怪抓走了
    观众听到了：师傅被妖怪抓走了
    演员说：妖怪哪里跑
    观众听到了：妖怪哪里跑
    演员说：师傅被妖怪抓走了
    观众听到了：师傅被妖怪抓走了
    演员说：妖怪哪里跑
    观众听到了：妖怪哪里跑