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 466862016@qq.com */ 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 466862016@qq.com */ 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 466862016@qq.com */ 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个苹果 篮子里面没有苹果了,我好饿啊,我等待.... 篮子里面没有苹果了,我好饿啊,我等待.... 篮子里面没有苹果了,我好饿啊,我等待.... 篮子里面没有苹果了,我好饿啊,我等待.... 篮子里面没有苹果了,我好饿啊,我等待.... 篮子里面没有苹果了,我好饿啊,我等待.... 篮子里面没有苹果了,我好饿啊,我等待.... 篮子里面没有苹果了,我好饿啊,我等待....
对于上面的代码我们可以进行优化和不足之处,你看出哪里要进行优化吗?
相关推荐
Java多线程--生产者与消费者问题
java多线程实现生产者和消费者
java多线程经典模型生产者消费者java多线程经典模型生产者消费者java多线程经典模型生产者消费者java多线程经典模型生产者消费者java多线程经典模型生产者消费者java多线程经典模型生产者消费者java多线程经典模型...
编写一个“生产者-消费者”的多线程演示程序,两个生产者,一个消费者,可以存放产品的仓库容量为10,仓库用栈实现,并有同步功能,且能防止先消费后生产的情况。
使用一个共享队列,生产者把产品放入队列,消费者消费产品,实现简单的多线程示例.
java实现多线程经典模型生产者消费java实现多线程经典模型生产者消费java实现多线程经典模型生产者消费java实现多线程经典模型生产者消费java实现多线程经典模型生产者消费java实现多线程经典模型生产者消费java实现...
用java多线程简易实现生产者消费者模式的代码,用java多线程简易实现生产者消费者模式的代码。
生产者消费者模式是java多线程经典的安全,它用到了同步,资源共享,wait,notify等技术。
用java多线程,实现生产者消费者同步和互斥的问题,操作系统中的经典问题
java多线程实现生产者消费者关系,完成线程之间的同步。
本代码是用JAVA实现的生产者与消费者的问题,线程间的同步与互斥功能
Java线程:并发协作-生产者消费者模型 Java线程:并发协作-死锁 Java线程:volatile关键字 Java线程:新特征-线程池 Java线程:新特征-有返回值的线程 Java线程:新特征-锁(上) Java线程:新特征-锁(下) ...
Java线程:并发协作-生产者消费者模型 Java线程:并发协作-死锁 Java线程:volatile关键字 Java线程:新特征-线程池 Java线程:新特征-有返回值的线程 Java线程:新特征-锁(上) Java线程:新特征-锁(下) Java...
【IT十八掌徐培成】Java基础第08天-04.多线程-生产者-消费者.zip
【IT十八掌徐培成】Java基础第08天-05.多线程-生产者-消费者2.zip
生产者-消费者实例可以很好帮助初学java的同学们理解和学习多线程的知识
NULL 博文链接:https://hbkh2000.iteye.com/blog/378843
利用线程间的通信主要是因为当多个线程同时对一个对象进行访问的时候,多个线程之间是一个协助的关系,举个例子就是今天要说的生产这和消费者模型。
基本满足操作系统课上要求,java实现的生产者消费者模型。
由生产者/消费者问题看JAVA多线程,让我们更加的了解多线程问题