码迷,mamicode.com
首页 > 编程语言 > 详细

Java 多线程实现生产者消费者问题(wait/notify)

时间:2015-04-09 08:57:51      阅读:147      评论:0      收藏:0      [点我收藏+]

标签:java多线程   生产者消费者   例子   wait notify   

本文参考网上一些例子,使用synchronized及对象的wait/notify方法实现。

首先定义3个类,一个是容器类,属性有容器最大容量和当前容量;

另外两个分别是生产者和消费者类,二者分别有生产方法和消费方法(均在各自的run方法中实现,实际上最好抽离出来成为一个单独的方法)


package test3;

class Container{
	public int max; //定义容器最大容量
	public int currentNum;//定义容器当前容量
	
	public Container(int max){
		this.max = max;
		currentNum = 0;
	}
}
class Producer implements Runnable{
	public Container con;
	public Producer(Container con){
		this.con = con;
	}
	public void run(){
		while(true){//有无数个苹果
			synchronized(con){
				if(con.currentNum < con.max){//若当前容器不满,则可以生产
					con.notify();//生产完则通知并释放锁
					con.currentNum++;
					System.out.println(" 生产者正在生产...+1, 当前产品数:"+con.currentNum);
				}else if(con.currentNum == con.max){//
					System.out.println("箱子已经饱和,生产者停止生产,正在等待消费...");	
					try {
						con.wait();
					} catch (InterruptedException e) {
						e.printStackTrace();
					}
				}//if else if				
			}//syn	执行完同步块	释放锁,输出结果中连续出现两次生产者是因为:释放锁后,若没有等待线程,则还是先执行到哪个线程的同步块就执行它
			
			try {
				Thread.sleep(100);//调节生产者频率,过快容易猝死~~
			} catch (InterruptedException e) {
				e.printStackTrace();
			}//try
		}//while
	}
}

class Consumer implements Runnable{
	public Container con;
	public Consumer(Container con){
		this.con = con;
	}
	public void run(){
		while(true){
			synchronized(con){
				if(con.currentNum > 0 ){
					con.notify();
					con.currentNum--;
					System.out.println(" 消费者正在消费...-1, 当前产品数:"+con.currentNum);
				}else if(con.currentNum == 0){
					System.out.println("箱子已经空了,消费者停止消费,正在等待生产...");	
					try {
						con.wait();
					} catch (InterruptedException e) {
						e.printStackTrace();
					}
				}//else if				
			}//syn		
			
			try {
				Thread.sleep(140);//调节消费者频率,过快容易撑死~~
			} catch (InterruptedException e) {
				e.printStackTrace();
			}//try
		}//while
	}// run
}
public class TestProducerConsumer{
	public static void main(String args[]){
		Container container = new Container(5);//定义箱子最大容量,此处为5
		Producer producer =  new Producer(container);//箱子中的苹果数要同步,所以将箱子对象引用作为形参传给生产者和消费者
		Consumer consumer = new Consumer(container);//
		
		new Thread(producer, "producer").start();//启动生产消费模式
		new Thread(consumer, "consumer").start();
	}
}

程序输出:

 生产者正在生产...+1, 当前产品数:1
 消费者正在消费...-1, 当前产品数:0
 生产者正在生产...+1, 当前产品数:1
 消费者正在消费...-1, 当前产品数:0
 生产者正在生产...+1, 当前产品数:1
 消费者正在消费...-1, 当前产品数:0
 生产者正在生产...+1, 当前产品数:1
 消费者正在消费...-1, 当前产品数:0
 生产者正在生产...+1, 当前产品数:1
 生产者正在生产...+1, 当前产品数:2
 消费者正在消费...-1, 当前产品数:1
 生产者正在生产...+1, 当前产品数:2
 消费者正在消费...-1, 当前产品数:1
 生产者正在生产...+1, 当前产品数:2
 消费者正在消费...-1, 当前产品数:1
 生产者正在生产...+1, 当前产品数:2
 生产者正在生产...+1, 当前产品数:3
 消费者正在消费...-1, 当前产品数:2
 生产者正在生产...+1, 当前产品数:3
 消费者正在消费...-1, 当前产品数:2
 生产者正在生产...+1, 当前产品数:3
 消费者正在消费...-1, 当前产品数:2
 生产者正在生产...+1, 当前产品数:3
 消费者正在消费...-1, 当前产品数:2
 生产者正在生产...+1, 当前产品数:3
 生产者正在生产...+1, 当前产品数:4
 消费者正在消费...-1, 当前产品数:3
 生产者正在生产...+1, 当前产品数:4
 消费者正在消费...-1, 当前产品数:3
 生产者正在生产...+1, 当前产品数:4
 消费者正在消费...-1, 当前产品数:3
 生产者正在生产...+1, 当前产品数:4
 生产者正在生产...+1, 当前产品数:5
 消费者正在消费...-1, 当前产品数:4
 生产者正在生产...+1, 当前产品数:5
 消费者正在消费...-1, 当前产品数:4
 生产者正在生产...+1, 当前产品数:5
 消费者正在消费...-1, 当前产品数:4
 生产者正在生产...+1, 当前产品数:5
 消费者正在消费...-1, 当前产品数:4
 生产者正在生产...+1, 当前产品数:5
箱子已经饱和,生产者停止生产,正在等待消费...
 消费者正在消费...-1, 当前产品数:4
 生产者正在生产...+1, 当前产品数:5
 消费者正在消费...-1, 当前产品数:4
 生产者正在生产...+1, 当前产品数:5
 消费者正在消费...-1, 当前产品数:4
 生产者正在生产...+1, 当前产品数:5
 消费者正在消费...-1, 当前产品数:4
 生产者正在生产...+1, 当前产品数:5
箱子已经饱和,生产者停止生产,正在等待消费...
 消费者正在消费...-1, 当前产品数:4
 生产者正在生产...+1, 当前产品数:5
 消费者正在消费...-1, 当前产品数:4
 生产者正在生产...+1, 当前产品数:5
 消费者正在消费...-1, 当前产品数:4
 生产者正在生产...+1, 当前产品数:5
 消费者正在消费...-1, 当前产品数:4
 生产者正在生产...+1, 当前产品数:5
箱子已经饱和,生产者停止生产,正在等待消费...
 消费者正在消费...-1, 当前产品数:4
 生产者正在生产...+1, 当前产品数:5
 消费者正在消费...-1, 当前产品数:4
 生产者正在生产...+1, 当前产品数:5
 消费者正在消费...-1, 当前产品数:4
 生产者正在生产...+1, 当前产品数:5
 消费者正在消费...-1, 当前产品数:4
 生产者正在生产...+1, 当前产品数:5
箱子已经饱和,生产者停止生产,正在等待消费...
 消费者正在消费...-1, 当前产品数:4
 生产者正在生产...+1, 当前产品数:5
 消费者正在消费...-1, 当前产品数:4
 生产者正在生产...+1, 当前产品数:5
 消费者正在消费...-1, 当前产品数:4
 生产者正在生产...+1, 当前产品数:5
 消费者正在消费...-1, 当前产品数:4
 生产者正在生产...+1, 当前产品数:5
箱子已经饱和,生产者停止生产,正在等待消费...
 消费者正在消费...-1, 当前产品数:4
 生产者正在生产...+1, 当前产品数:5
 消费者正在消费...-1, 当前产品数:4
 生产者正在生产...+1, 当前产品数:5


Java 多线程实现生产者消费者问题(wait/notify)

标签:java多线程   生产者消费者   例子   wait notify   

原文地址:http://blog.csdn.net/lingzhm/article/details/44946573

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!