/**
*
*/
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 + "个产品" );
}
}
*
*/
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 + "个产品" );
}
}
}
本文转自danni505 51CTO博客，原文链接：http://blog.51cto.com/danni505/213478，如需转载请自行联系原作者
