package testThread; public class Test3 { public static void main(String[] args) { Clerk c = new Clerk(); //消费时不生产，生产时不消费 //生产者 new Thread(new Runnable ...
分类：
编程语言 时间：
2019-12-21 15:58:29
阅读次数：
97
什么是生产者-消费者模式 比如有两个进程A和B，它们共享一个固定大小的缓冲区，A进程产生数据放入缓冲区，B进程从缓冲区中取出数据进行计算，那么这里其实就是一个生产者和消费者的模式，A相当于生产者，B相当于消费者，生产者消费者要解决的问题就是如何处理公共资源。 生产者-消费者模式的特点 保证生产者不会 ...
分类：
编程语言 时间：
2019-12-20 23:57:49
阅读次数：
179
线程 1，生产者消费者模型 1. 什么是生产者与消费者模型 生产者消费者模式是通过一个容器来解决生产者和消费者的强耦合问题，生产者和消费者之间不直接通讯，而通过阻塞队列来通讯，阻塞队列就相当于一个缓冲区，平衡了生产者和消费者的处理能力 在并发编程中使用生产者和消费者模式能够解决大多数并发问题，该模式 ...
分类：
编程语言 时间：
2019-12-13 13:46:51
阅读次数：
89
概念阻塞队列（BlockingQueue）是一个支持两个附加操作的队列。这两个附加的操作是：在队列为空时，获取元素的线程会等待队列变为非空。当队列满时，存储元素的线程会等待队列可用。应用阻塞队列常用于生产者和消费者的场景，生产者是往队列里添加元素的线程，消费者是从队列里拿元素的线程。阻塞队列就是生 ... ...
分类：
编程语言 时间：
2019-12-12 01:14:35
阅读次数：
93
1. 什么是阻塞队列？ 阻塞队列（BlockingQueue）是一个支持两个附加操作的队列。这两个附加的操作是：在队列为空时，获取元素的线程会等待队列变为非空。当队列满时，存储元素的线程会等待队列可用。阻塞队列常用于生产者和消费者的场景，生产者是往队列里添加元素的线程，消费者是从队列里拿元素的线程。 ...
分类：
其他好文 时间：
2019-12-10 18:38:55
阅读次数：
96
RocketMQ是阿里开源的分布式消息中间件，跟其它中间件相比，RocketMQ的特点是纯JAVA实现；集群和HA实现相对简单；在发生宕机和其它故障时消息丢失率更低。 一.RocketMQ专业术语 Producer（生产者） 消息生产者，位于用户的进程内，Producer通过NameServer获取 ...
分类：
其他好文 时间：
2019-12-07 23:06:19
阅读次数：
134
Kafka入门介绍 https://www.cnblogs.com/swordfall/p/8251700.html最近在看hdoop的hdfs 以及看了下kafka的底层存储，发现分布式的技术基本上都是相同的。 都是通过增加一个coordinator的节点作为存储元数据， 将实体数据放到datan ...
分类：
其他好文 时间：
2019-12-01 09:52:12
阅读次数：
85
生产者 引入依赖 <dependency> <groupId>junit</groupId> <artifactId>junit</artifactId> <version>3.8.1</version> <scope>test</scope> </dependency> <dependency> ...
分类：
其他好文 时间：
2019-11-30 17:41:06
阅读次数：
121
事先准备: 1:将zk集群安装到linux系统上并启动,我这里是安装了三台,当然你也可以使用linxu或者windows的单机版,windows单机版的使用和配置都比较简单 2:(此步可以不用)将dubbo-admin安装到linxu上的tomcat中,用于查看生产者和消费者的使用情况,就是dubb ...
分类：
编程语言 时间：
2019-11-30 17:39:54
阅读次数：
109
以上是一个massege模式，消息的存入和 获取都会加锁，同时也这是了对最大存储的限制，如果超过了限制，就会将线程先阻塞，如果没有消息，就不允许获取信息 生产者线程，将每一个线程生产的数据，都塞到消息队列中 以上是消费者和对生产消费者模式的调用 由于生产者和消费者都是在不断地循环，所以程序在一直得生 ...
分类：
其他好文 时间：
2019-11-25 19:01:39
阅读次数：
67
