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_多线程_并发协作模型_生产者消费者模式_管程法