以下出现代码均为伪代码； 2.5.1 生产者 消费者问题（考试模型占比 60%） 分析上图：缓冲区存在互斥问题，生产者与消费者之间还 存在同步问题 1. 利用 记录型信号量 解决生产者 消费者问题(==背下来==) 假定在生产者和消费者之间的共用缓冲池中具有n个缓冲区，这时可以利用互斥信号量mute ...
分类：
系统相关 时间：
2020-05-11 00:57:40
阅读次数：
88
上一篇，讲了RabbitMQ的具体用法，可以看看这篇文章：RabbitMQ学习系列（三）: C# 如何使用 RabbitMQ。今天说些理论的东西，Exchange 的几种模式。 AMQP协议中的核心思想就是生产者和消费者隔离，生产者从不直接将消息发送给队列。生产者通常不知道是否一个消息会被发送到队列 ...
分类：
其他好文 时间：
2020-05-09 17:12:38
阅读次数：
76
转： 线程池的三种队列区别：SynchronousQueue、LinkedBlockingQueue 和ArrayBlockingQueue 线程池的三种队列区别：SynchronousQueue、LinkedBlockingQueue 和ArrayBlockingQueue置顶 无名后生 2018 ...
分类：
数据库 时间：
2020-05-08 16:28:24
阅读次数：
140
阻塞队列 概念 队列 队列就可以想成是一个数组，从一头进入，一头出去，排队买饭 阻塞队列 BlockingQueue 阻塞队列，排队拥堵，首先它是一个队列，而一个阻塞队列在数据结构中所起的作用大致如下图所示： 线程1往阻塞队列中添加元素，而线程2从阻塞队列中移除元素 当蛋糕店的柜子空的时候，无法从柜 ...
分类：
其他好文 时间：
2020-05-01 00:46:29
阅读次数：
46
一、ReactiveX 与 RxJava ReactiveX 的全称为Reactive Extension，一般缩写为 Rx，即我们平常所说的反应式编程。其设计原理主要使用了观察者模式，区分数据的生产者和消费者，通过事件流的方式进行数据的异步处理。 RxJava 是 ReactiveX Java语言 ...
分类：
编程语言 时间：
2020-04-27 17:14:00
阅读次数：
69
Kafka 属于分布式的消息引擎系统 它的主要功能是提供一套完备的消息发布与订阅解决方案 在 Kafka 中，发布订阅的对象是主题（Topic），你可以为每个业务、每个应用甚至是每类数据都创建专属的主题 我们把生产者和消费者统称为客户端（Clients） 向主题发布消息的客户端应用程序称为生产者（P ...
分类：
其他好文 时间：
2020-04-27 13:38:33
阅读次数：
59
阻塞队列（BlockingQueue）是一个支持两个附加操作的队列。 这两个附加的操作是：在队列为空时，获取元素的线程会等待队列变为非空。当 队列满时，存储元素的线程会等待队列可用。 阻塞队列常用于生产者和消费者的场景，生产者是往队列里添加元素的线程，消 费者是从队列里拿元素的线程。阻塞队列就是生产 ...
分类：
其他好文 时间：
2020-04-25 01:11:11
阅读次数：
64
MQ全称为Message Queue,是一种应用程序对应用程序的通信方法，应用程序通过读写出入消息队列的数据来通信，从而无需专用连接来链接他们（如RPC）。 消息队列是典型的生产者和消费者模型，生产者和消费者只关心消息的发送和接受，没有业务逻辑的侵入，实现了生产者和消费者的解耦。 AMQP：一个提供 ...
分类：
其他好文 时间：
2020-04-23 22:56:09
阅读次数：
72
1.sleep()是Thread类的方法;而wait(),notify(),notifyAll()是Object类中定义的方法；2.Thread.sleep和Object.wait都会暂停当前的线程,Thread.sleep不会造成当前锁行为的变化,如果当前线程有锁,调用之后并不会释放锁;而Object.wait会释放当前对象锁.代码实现:packagetest111;importjava.uti
分类：
其他好文 时间：
2020-04-16 10:24:55
阅读次数：
76
1.queue是点对点模式，一条消息对应一个消费者，topic是一对多模式，一条消息可能有一个或多个消费者 2.queue模式消息再发送后消费者可以在之后的任意时间消费，topic模式如果没有订阅者消息就是废消息，会被丢弃。 3.queue模式生产者与消费者之间没有时间相关性，topic模式下生产者 ...
分类：
其他好文 时间：
2020-04-08 22:28:23
阅读次数：
69
