天天看点

java 生产者消费者问题 并发问题的解决(转)

引言

  生产者和消费者问题是线程模型中的经典问题:生产者和消费者在同一时间段内共用同一个存储空间,如下图所示,生产者向空间里存放数据,而消费者取用数据,如果不加以协调可能会出现以下情况:

java 生产者消费者问题 并发问题的解决(转)

生产者消费者图

  存储空间已满,而生产者占用着它,消费者等着生产者让出空间从而去除产品,生产者等着消费者消费产品,从而向空间中添加产品。互相等待,从而发生死锁。

  生产者消费者问题是研究多线程程序时绕不开的经典问题之一,它描述是有一块缓冲区作为仓库,生产者可以将产品放入仓库,消费者则可以从仓库中取走产品。解决生产者/消费者问题的方法可分为两类:

  (1)采用某种机制保护生产者和消费者之间的同步;

  (2)在生产者和消费者之间建立一个管道。

  第一种方式有较高的效率,并且易于实现,代码的可控制性较好,属于常用的模式。第二种管道缓冲区不易控制,被传输数据对象不易于封装等,实用性不强。因此本文只介绍同步机制实现的生产者/消费者问题。

  同步问题核心在于:如何保证同一资源被多个线程并发访问时的完整性。常用的同步方法是采用信号或加锁机制,保证资源在任意时刻至多被一个线程访问。Java语言在多线程编程上实现了完全对象化,提供了对同步机制的良好支持。在Java中一共有四种方法支持同步,其中前三个是同步方法,一个是管道方法。

(1)wait() / notify()方法

(2)await() / signal()方法

(3)BlockingQueue阻塞队列方法

(4)PipedInputStream / PipedOutputStream

本文只介绍最常用的前两种种,第三、四种暂不做讨论,有兴趣的读者可以自己去网上找答案。

一、wait() / notify()方法

  wait() / nofity()方法是基类Object的两个方法,也就意味着所有Java类都会拥有这两个方法,这样,我们就可以为任何对象实现同步机制。

  wait()方法:当缓冲区已满/空时,生产者/消费者线程停止自己的执行,放弃锁,使自己处于等等状态,让其他线程执行。

  notify()方法:当生产者/消费者向缓冲区放入/取出一个产品时,向其他等待的线程发出可执行的通知,同时放弃锁,使自己处于等待状态。

代码实现:

1、仓库类

java 生产者消费者问题 并发问题的解决(转)
java 生产者消费者问题 并发问题的解决(转)

2、生产者

java 生产者消费者问题 并发问题的解决(转)
java 生产者消费者问题 并发问题的解决(转)

3、消费者

java 生产者消费者问题 并发问题的解决(转)
java 生产者消费者问题 并发问题的解决(转)

4、测试类

java 生产者消费者问题 并发问题的解决(转)
java 生产者消费者问题 并发问题的解决(转)

5、结果:

java 生产者消费者问题 并发问题的解决(转)
java 生产者消费者问题 并发问题的解决(转)

  看完上述代码,对wait() / notify()方法实现的同步有了了解。你可能会对Storage类中为什么要定义public void produce(int num);和public void consume(int num);方法感到不解,为什么不直接在生产者类Producer和消费者类Consumer中实现这两个方法,却要调用Storage类中的实现呢?淡定,后文会有解释。我们先往下走。

二、await() / signal()方法

  在JDK5.0之后,Java提供了更加健壮的线程处理机制,包括同步、锁定、线程池等,它们可以实现更细粒度的线程控制。await()和signal()就是其中用来做同步的两种方法,它们的功能基本上和wait() / nofity()相同,完全可以取代它们,但是它们和新引入的锁定机制Lock直接挂钩,具有更大的灵活性。通过在Lock对象上调用newCondition()方法,将条件变量和一个锁对象进行绑定,进而控制并发程序访问竞争资源的安全。

  下面来看代码:  

  只需要更新仓库类Storage的代码即可,生产者Producer、消费者Consumer、测试类Test的代码均不需要进行任何更改。

仓库类

java 生产者消费者问题 并发问题的解决(转)
java 生产者消费者问题 并发问题的解决(转)

结果:

java 生产者消费者问题 并发问题的解决(转)
java 生产者消费者问题 并发问题的解决(转)

  

  这样我们就知道为神马我要在Storage类中定义public void produce(int num);和public void consume(int num);方法,并在生产者类Producer和消费者类Consumer中调用Storage类中的实现了吧。将可能发生的变化集中到一个类中,不影响原有的构架设计,同时无需修改其他业务层代码。

总结

  两种方式原理一致,都是对独占空间加锁,阻塞和唤醒线程,第一种方式比较传统,第二种方式速度比较快。

http://www.cnblogs.com/0201zcr/p/4758533.html