首页 > 代码库 > java生产者消费者并发协作

java生产者消费者并发协作

  随着职务转变,代码荒废很久了,很多时间都是在沟通需求,作为一名技术员,不写代码就感觉是在自废武功,慢慢颓废了很多,今天重新回顾了下JAVA线程知识,基础知识就不梳理了,网上也很多,主要关键几个状态位(新建、可运行、正在运行、阻塞等)和几个关键方法(sleep、yield、wait、notify、notifyAll等)搞清楚,基础应用知识应该了解的就差不多了,想深入了解的推荐看《JAVA并发编程实战》。废话不多说了,直接上例子,看了下网上的大致思路,结合实际应用时的场景,自己编写了一个例子,不到位的地方请大家及时指正,谢谢!

  例子:经典的生产者和消费者,多线程环境下协作生产和消费:多个生产者同时执行生产任务,多个消费者同时执行消费任务,当产品已满时,生产者们就等待,将锁交给消费者们,消费者开始消费,当没有产品可消费时,消费者等待,将锁交给生产者,生产者开始生产。定义总生产上限MAX_PRODUCE和每个生产者最大生产能力(上限)MAX_SIGNLE_PRODUCE以及每个消费者单次最大可消费数量MAX_SINGLE_CONSUME,特别说明下:如果单次生产后总生产量没有达到上限,这个时候生产者交出的锁可能被消费者获取到进行消费,也可能被生产者获取到继续生产,反观消费者也是同样的道理。因为在多线程环境下,所有生产线程之间、消费线程之间以及生产线程和消费线程之间会重叠进行(运行时间较短的情况下,可能观测到所有产品被某一个线程生产或者被某一个线程消费,将RUN运行结果保存到文件中,稍微运行时间久点,就能观察多个生产者同时并发生产产品或多个消费者并发消费产品的状况)。

技术分享

技术分享

技术分享

技术分享

技术分享

技术分享

运行结果:

技术分享

技术分享

 

java生产者消费者并发协作