java_多线程_信号灯法

最新推荐文章于 2022-02-28 21:35:22 发布

xixihaha_coder

最新推荐文章于 2022-02-28 21:35:22 发布

阅读量201

点赞数 1

分类专栏：多线程 Java 文章标签：多进程 java

本文链接：https://blog.csdn.net/xixihaha_coder/article/details/118270448

版权

Java 同时被 2 个专栏收录

43 篇文章

订阅专栏

多线程

14 篇文章

订阅专栏

本文通过Java实现了一个典型的生产者消费者问题解决方案，利用信号灯法和标志位来同步生产者（演员）与消费者（观众）之间的操作。代码中定义了演员类Player和观众类Watcher，二者通过TV类进行交互。

摘要生成于 C知道，由 DeepSeek-R1 满血版支持，前往体验 >

信号灯法

标志位解决

package com.test3;

//测试生产者消费者问题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++) {
			this.tv.watch();
		}
	}
}

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

	// 表演
	public synchronized void play(String voice) {
		if (!flag) {
			try {
				this.wait();
			} catch (InterruptedException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}

		System.out.println("演员表演了：" + voice);
		// 通知观众观看
		this.notifyAll();
		this.voice = voice;
		this.flag = !flag;
	}

	// 观看
	public synchronized void watch() {
		if (flag) {
			try {
				this.wait();
			} catch (InterruptedException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
		System.out.println("观看了:" + voice);
		// 通知演员表演
		this.notifyAll();
		this.flag = !flag;
	}
}