多线程之生产者与消费者问题
之前感觉很简单,但是有一次面试让我在纸上写,居然没写对丢人啊。
生产者消费者问题(Producer-consumer problem):生产者不断地生产产品,消费者取走生产者生产的产品。生产者生产出产品后将其放到一个区域之中,消费者从这个地方去除数据。
涉及的问题:要保证生产者不会在缓冲区满时加入数据,消费者也不会在缓冲区中空时消耗数据。
主要涉及:多线程的同步问题。
1、假设生产者线程刚向数据存储空间添加了产品的名称,还没有添加产品的内容,程序就切到了消费者的线程,消费这的
线程将吧产品的名称和上一个产品的内容联系到了一起。
2、生产者放了若干次的产品,消费者才开始取产品,或者是,消费者去玩一个产品后,还没等待生产者生产新的产品,有
重复的去除已经去过的产品。
其生产者消费者问题程序实现如下:
一、产品:
package andy.thread.test; /** * @author andy * @version:2015-3-20 上午10:09:42 * * */ public class Product { private String pName; private String pContent; private boolean flag; // 此为产品的标记 true为已有产品 false为没有产品 //生产 public synchronized void put(String pName, String pContent) { if (flag) {// 如果有产品,等待消费 try { super.wait(); } catch (InterruptedException e) { e.printStackTrace(); } } this.setpName(pName); try { Thread.sleep(300); } catch (InterruptedException e) { e.printStackTrace(); } this.setpContent(pContent); System.out.println("生产产品"); this.flag = true; // 标记为以生产,唤醒消费 super.notify(); } //消费 public synchronized void romve() { if (!flag) { // 没有产品时等待 try { super.wait(); } catch (InterruptedException e) { e.printStackTrace(); } } try { Thread.sleep(300); } catch (InterruptedException e) { e.printStackTrace(); } System.out .println("消费:" + this.getpName() + "---" + this.getpContent()); this.flag = false; // 已消费,可以进行生产了 super.notify(); } public String getpName() { return pName; } public void setpName(String pName) { this.pName = pName; } public String getpContent() { return pContent; } public void setpContent(String pContent) { this.pContent = pContent; } }
二、生产者
package andy.thread.test; import java.util.concurrent.TimeUnit; /** * @author andy * @version:2015-3-20 上午11:05:53 * * */ public class Producer implements Runnable { private Product product = null; public Producer(Product product) { this.product = product; } @Override public void run() { for (int i = 0; i < 50; i++) { try { TimeUnit.SECONDS.sleep(5); } catch (InterruptedException e) { e.printStackTrace(); } product.put("产品" + i, i + ""); } } }
三、消费者
package andy.thread.test; import java.util.concurrent.TimeUnit; /** * @author andy * @version:2015-3-20 上午10:56:18 * * */ public class Consumer implements Runnable{ private Product product = null; public Consumer(Product product){ this.product = product; } @Override public void run() { for (int i = 0; i < 50; i++) { try { TimeUnit.SECONDS.sleep(5); } catch (InterruptedException e) { e.printStackTrace(); } this.product.romve(); } } }
测试:
package andy.thread.test; /** * @author andy * @version:2015-3-20 上午11:12:25 * * */ public class ConsumerProducerTest { /** * @param args */ public static void main(String[] args) { Product product = new Product(); Producer producer = new Producer(product); Consumer consumer = new Consumer(product); new Thread(producer).start(); new Thread(consumer).start(); } }
结果如下:
郑重声明:本站内容如果来自互联网及其他传播媒体,其版权均属原媒体及文章作者所有。转载目的在于传递更多信息及用于网络分享,并不代表本站赞同其观点和对其真实性负责,也不构成任何其他建议。