标签：Java int public 信号灯 Waiter flag new 多线程 id

package cn.thread4;

/**
 * 并发协作模型
 * 生产者消费者实现方式之一
 * 信号灯法
 * 没有缓冲容器，不可以实现存量生产消费，现做现卖，没存货或者认为短暂存货1
 * @author Chill Lyn
 *
 */
public class SignalLampMethod {
	public static void main(String[] args) {
		Waiter w = new Waiter();
		new Thread(new Producer2(007, w)).start();
		new Thread(new Consumer2(123, w)).start();
	}
}

//生产者
class Producer2 implements Runnable {
	int id;
	Waiter w;

	public Producer2(int id, Waiter w) {
		super();
		this.id = id;
		this.w = w;
	}

	@Override
	public void run() {
		for (int i = 1; i < 10; i++) {
			w.set(new Data2(i));
		}
	}
}

//消费者
class Consumer2 implements Runnable {
	int id;
	Waiter w;

	public Consumer2(int id, Waiter w) {
		super();
		this.id = id;
		this.w = w;
	}

	@Override
	public void run() {
		for (int i = 1; i < 10; i++) {
			w.get();
		}
	}
}

//缓冲区
class Waiter {
//	默认False,消费者等待，生产者生产
//	True：生产者等待，消费者生产
	boolean flag;
	Data2 data;

//	生产者生产存
	public synchronized void set(Data2 data) {
		while (flag) {
			try {
				this.wait();
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		}
		System.out.println("生产了一个Data");
		flag = !flag;
		this.notifyAll();
	}

//	消费者取出
	public synchronized void get() {
		while (!flag) {
			try {
				this.wait();
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		}
		System.out.println("消费了一个Data");
		flag = !flag;
		this.notifyAll();
	}
}

//数据
class Data2 {
	int id;

	public Data2(int id) {
		super();
		this.id = id;
	}
}

参考结果

管程法请见：Java_多线程_并发协作模型_生产者消费者模式_管程法

标签：Java,int,public,信号灯,Waiter,flag,new,多线程,id
来源： https://blog.csdn.net/Chill_Lyn/article/details/100044448

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