Java生产者_Java实现生产者消费者

超、凢脫俗 2022-11-07 05:28 149阅读 0赞

方法1：最简单--利用LinkedBlockingQueue

队列具有先进先出的特点，成为经常应用于生产-消费者模式的数据结构。

1.将一个对象放到队列尾部，如果队列已满，就等待直到有空闲节点。 ——put()方法

2.从队列头部取一个对象，如果没有对象，就等待直到有对象可取。 ——take()方法

3.在存取队列的过程中，锁定队列对象，不允许其它线程访问队列。——使得它是线程安全的

下面的代码适用于多个生产者、多个消费者。

![ContractedBlock.gif][] Pruducer.java

![ContractedBlock.gif][] Consumer.java

![ContractedBlock.gif][] Main.java

方法2：不采用BlockingQueue，利用lock、Condition来实现

思路：

利用可重用的LinkedList来存放资源，生产者addLast()，消费者removeFirst()。

使用ReentrantLock()来实现消费者和生产者的同步;//可重用的互斥锁

思考：为什么使用了lock后，还使用了它的2个newCondition，这样做有什么好处？

![ContractedBlock.gif][] ProducerConsumer .java

关于Java线程的lock、condition、synchronized的小小总结：

1.synchronized简单易用，但是功能受局限，无法满足复杂的同步机制，比如“读者写者问题”：多个读者线程是不互斥的。

2.lock以更优雅的方式来解决线程同步，比如读写锁ReadWriteLock。

3.Condition解决线程间通信，为不同的线程建立不同的条件。

Condition可以替代传统的线程间通信，用await()替换wait()，用signal()替换notify()，用signalAll()替换notifyAll()。

——为什么方法名不直接叫wait()/notify()/nofityAll()？因为Object的这几个方法是final的，不可重写！

Condition实现了BlockingQueue的功能。

看看BlockingQueue的继承和实现。

![181036509273179.png][ContractedBlock.gif]

一般的锁Lock的实现：注意ReadLock、WriteLock是内部的静态类，只有ReentrantReadWriteLock类可以调用。

![180946327879836.png][ContractedBlock.gif]

读写的锁ReadWriteLock

![180943360062012.png][ContractedBlock.gif]

思考：OS的信号量是什么，线程通信的方式有哪些？共享变量和消息传递。

信号量与互斥锁有什么联系？

[ContractedBlock.gif]:

发表评论取消回复

表情：

评论列表（有 0 条评论，149人围观）

还没有评论，来说两句吧...

相关阅读

相关生产者-消费者模式Java实现

> 生产者-消费者是多线程协作中非常典型的例子！ > 主要是生产者负责生产产品，然后消费者进行消费，但是这样的模式有几个前提 > ①生产者在生产前必须判断消费者线程是否

太过爱你忘了你带给我的痛/ 2022年11月29日 03:01/ 0 赞/ 107 阅读

相关 Java实现生产者消费者模型

package pc; import java.util.ArrayList; public class LockObj {

忘是亡心i/ 2022年11月18日 02:21/ 0 赞/ 138 阅读

相关 Java生产者_Java实现生产者消费者

方法1：最简单--利用LinkedBlockingQueue 队列具有先进先出的特点，成为经常应用于生产-消费者模式的数据结构。 1.将一个对象放到队列尾部，如果队列已满，

超、凢脫俗/ 2022年11月07日 05:28/ 0 赞/ 150 阅读

相关 [Java] 生产者消费者Java实现

1 概述 -------------------- 生产者消费者问题是多线程的一个经典问题，它描述是有一块缓冲区作为仓库，生产者可以将产品放入仓库，消费者则可以从仓库中

缺乏、安全感/ 2022年05月26日 08:18/ 0 赞/ 137 阅读

相关生产者消费者模式-Java实现

生产消费者模型　　　　生产者消费者模型具体来讲，就是在一个系统中，存在生产者和消费者两种角色，他们通过内存缓冲区进行通信，生产者生产消费者需要的资料，消费者把资料做成

柔情只为你懂/ 2022年05月26日 06:50/ 0 赞/ 137 阅读

相关 Java实现生产者消费者模式

介绍生产者消费者模式的四种不同实现 -------------------- 实现1：Object，wait，notifyAll 说明：生成String对象作为

不念不忘少年蓝@/ 2022年05月16日 09:34/ 0 赞/ 175 阅读

相关 Java生产者消费者模型

生产者和消费者主要的一个点就是对缓冲区的状态做出变化。当生产者生产的资源满，生产者阻塞，若不满，则继续生产。当消费者消费资源为空，消费者阻塞，若不空，则继续消费。当

╰半橙微兮°/ 2022年02月21日 12:48/ 0 赞/ 230 阅读

相关 kafka生产者消费者java

1、HDP EpointKafkaUtil.java package com.epoint.core.utils.hadoop; import

深碍√TFBOYSˉ_/ 2022年02月13日 14:19/ 0 赞/ 262 阅读

相关生产者消费者模型java实现

方法一：利用synchronized，wait()和notify() public class WaitAndNotify { public stat

系统管理员/ 2021年10月01日 10:50/ 0 赞/ 332 阅读

相关 Java实现消费者生产者

import java.util.LinkedList; / @auther: 巨未 @DATE: 2021/9/7 0007 23:45 @D

忘是亡心i/ 2021年09月25日 15:00/ 0 赞/ 323 阅读