Producer & Consumer

/**
*
*/
package mythread;

/**
* @author daniel zhou
* 演示生产者、消费者模型
*/
public class WaitAndNotify {

/**
* @param args
*/
public static void main(String[] args) {
// 定义一个储物罐
Queue q = new Queue();
// 生产者
producer p = new producer(q);
// 消费者
consumer c = new consumer(q);
// 开始生产、消费过程
p.start();
c.start();
System.gc();
}

}

/**
*
* @author daniel zhou 储物罐，用作存储生产者的产品
*/
class Queue {
// 产品编号
int value;
// 有无产品标示
boolean flag = false;

// 生产
public synchronized void put(int i) {
// 为空则放置，并通知消费者去取产品，自己则开始等待
if (!flag ) {
value = i;
flag = true;
// 通知消费者
notify();
}

// 开始等待
try {
wait();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}

// 消费
public synchronized int get() {
// 有产品则取，并标示已经置空，通知生产者放置，自己开始等待
if (!flag ) {

// 开始等待
try {
wait();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}

// 通知生产者并返回产品
flag = false;
notify();
return value;
}

}

/**
*
* @author daniel zhou 消费者
*/
class consumer extends Thread {
Queue q;

public consumer(Queue q) {
this.q = q;
}

// 消费10个产品
public void run() {
//这个while必须要
while(true){
System.out.println("消费者消费了第" + q.get() + "个产品");
}
}
}

/**
*
* @author daniel zhou 生产者
*/
class producer extends Thread {
Queue q;

public producer(Queue q) {
this.q = q;
}

// 生产10个产品
public void run() {
for (int i = 0; i < 10; i++) {
q.put(i);
System.out.println("生产者放置了第" + i + "个产品");
}
}
}