java多线程之-生产者与消费者

java多线程之-并发协作【生产者与消费者】模型

对于多线程程序来说，不管c/c++ java python 等任何编程语言，生产者与消费者模型都是最为经典的。也就是可以说多线程的并发协作

 对于此模型说明

1、生产者仅仅在仓库中未存贮满的时候生产，仓库满了就停止生产了。

2、消费者仅仅在仓库中有存储的产品才能消费，如果仓库为空就等待。

3、当消费者发现仓库中没有产品的时候回通知生产者进行生产

4、当生产者生产任何消费产品的时候，应该通知等待的消费者去消费。

 

package a;

import java.util.Queue;
import java.util.concurrent.LinkedBlockingQueue;

public class Main {

	
	private static  Queue<Apple> queue = new LinkedBlockingQueue<Main.Apple>();
	
	private final static int MAX_COUNT = 30;
	
	private static  Object lock = new Object();
	
	
	/**
	 * 苹果产品
	 * @author gaoyuandong
	 * @date   2015年7月24日 下午4:11:37
	 * @mail   [e-mail]
	 */
	private static class Apple {
		
		private String name;

		public String getName() {
			return name;
		}

		public void setName(String name) {
			this.name = name;
		}

		public Apple(String name) {
			super();
			this.name = name;
		}

		public Apple() {
			super();
			// TODO Auto-generated constructor stub
		}
		
		
	}
	/***
	 * 消费者
	 * @author gaoyuandong
	 * @date   2015年7月24日 下午4:09:49
	 * @mail   [e-mail]
	 */
	private static class Customer extends Thread {

		@Override
		public void run() {
			
			while (true) {
				
				synchronized (lock) {
					
					if(queue.isEmpty()) {
						try {
							System.err.println("篮子里面没有苹果了,我好饿啊，我等待....");
							lock.wait();
						} catch (InterruptedException e) {
							e.printStackTrace();
						}
					} else {
						queue.poll();
						System.err.println("篮子里面有苹果了,我要吃苹果.... 还剩下：" + queue.size() +"个苹果" );
						lock.notifyAll();
					}
					
					
				}
				try {
					Thread.sleep(1000);
				} catch (InterruptedException e) {
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
			}
			
		}
		
		
	}
	
	/***
	 * 生产者
	 * @author gaoyuandong
	 * @date   2015年7月24日 下午4:08:58
	 * @mail   [e-mail]
	 */
	private static class Producer extends Thread {
		
		@Override
		public void run() {
			
		
				while (true) {
					synchronized (lock) {
					if(queue.size() >= MAX_COUNT) {
						try {
							System.err.println("篮子中苹果已经放满了，我好累啊，我等待.....");
							lock.wait();
						} catch (InterruptedException e) {
							e.printStackTrace();
						}
					}else {
						queue.add(new Apple("xxxx"));
						System.err.println("我要往篮子里面放置苹果了.... 现在有" + queue.size() +"个苹果");
						lock.notifyAll();
					}
					
					
				}
					try {
						Thread.sleep(1000);
					} catch (InterruptedException e) {
						// TODO Auto-generated catch block
						e.printStackTrace();
					}
			}
		}
	}
	
	
	public static void main(String[] args) {
		
			for (int i = 0; i < 10; i++) {
				Customer customer = new Customer();
				customer.start();
			}
			
			
			Producer producer = new Producer();
			producer.start();
		
			
		
	}
}

 

输出结果:

我要往篮子里面放置苹果了.... 现在有1个苹果
篮子里面有苹果了,我要吃苹果.... 还剩下：0个苹果
篮子里面没有苹果了,我好饿啊，我等待....
篮子里面没有苹果了,我好饿啊，我等待....
篮子里面没有苹果了,我好饿啊，我等待....
篮子里面没有苹果了,我好饿啊，我等待....
篮子里面没有苹果了,我好饿啊，我等待....
我要往篮子里面放置苹果了.... 现在有1个苹果
篮子里面有苹果了,我要吃苹果.... 还剩下：0个苹果
篮子里面没有苹果了,我好饿啊，我等待....
篮子里面没有苹果了,我好饿啊，我等待....
篮子里面没有苹果了,我好饿啊，我等待....
篮子里面没有苹果了,我好饿啊，我等待....
篮子里面没有苹果了,我好饿啊，我等待....
我要往篮子里面放置苹果了.... 现在有1个苹果
篮子里面有苹果了,我要吃苹果.... 还剩下：0个苹果
篮子里面没有苹果了,我好饿啊，我等待....
篮子里面没有苹果了,我好饿啊，我等待....
篮子里面没有苹果了,我好饿啊，我等待....
篮子里面没有苹果了,我好饿啊，我等待....
篮子里面没有苹果了,我好饿啊，我等待....
篮子里面没有苹果了,我好饿啊，我等待....
篮子里面没有苹果了,我好饿啊，我等待....
篮子里面没有苹果了,我好饿啊，我等待....
篮子里面没有苹果了,我好饿啊，我等待....
篮子里面没有苹果了,我好饿啊，我等待....
我要往篮子里面放置苹果了.... 现在有1个苹果
篮子里面有苹果了,我要吃苹果.... 还剩下：0个苹果
我要往篮子里面放置苹果了.... 现在有1个苹果
篮子里面有苹果了,我要吃苹果.... 还剩下：0个苹果
篮子里面没有苹果了,我好饿啊，我等待....
篮子里面没有苹果了,我好饿啊，我等待....
篮子里面没有苹果了,我好饿啊，我等待....
篮子里面没有苹果了,我好饿啊，我等待....
篮子里面没有苹果了,我好饿啊，我等待....
篮子里面没有苹果了,我好饿啊，我等待....
篮子里面没有苹果了,我好饿啊，我等待....
篮子里面没有苹果了,我好饿啊，我等待....

 对于上面的代码我们可以进行优化和不足之处，你看出哪里要进行优化吗？