队列queue: 作用：程序之间解耦；提高运行效率 集群的基础： 经典的生产者消费者模型 ...
分类：
编程语言 时间：
2019-11-04 22:06:52
阅读次数：
107
生产者消费者模式是多线程中最为常见的模式：生产者线程(一个或多个)生成面包放进篮子里(集合或数组)，同时，消费者线程(一个或多个)从篮子里(集合或数组)取出面包消耗。虽然它们任务不同，但处理的资源是相同的，这体现的是一种线程间通信方式。
分类：
编程语言 时间：
2019-11-03 22:14:48
阅读次数：
85
kafka介绍： 作用： 系统之间解耦和 峰值压力缓冲 异步通信 特点：生产者消费者模式，先进先出（FIFO）保证顺序，自己不丢数据，默认每隔7天清理数据，高吞吐量，没有主从关系，依靠Zk协调 结构： topic：消息队列/分类 kafka里面的消息是有topic来组织的，简单的我们可以想象为一个队 ...
分类：
其他好文 时间：
2019-11-01 09:56:38
阅读次数：
84
一 .什么是 Disruptor 从功能上来看，Disruptor 是实现了“队列”的功能，而且是一个有界队列。那么它的应用场景自然就是“生产者-消费者”模型的应用场合了。 可以拿 JDK 的 BlockingQueue 做一个简单对比，以便更好地认识 Disruptor 是什么。 我们知道 Blo ...
分类：
其他好文 时间：
2019-10-28 01:04:20
阅读次数：
80
一、比较低级的办法是用wait和notify来解决这个问题。 消费者生产者问题： 这个问题是一个多线程同步问题的经典案例，生产者负责生产对象，消费者负责将生成者产生的对象取出，两者不断重复此过程。这过程需要注意几个问题： 不论生产者和消费者有几个，必须保证： 1.生产者每次产出的对象必须不一样，产生 ...
分类：
编程语言 时间：
2019-10-27 11:09:14
阅读次数：
90
#线程数据安全处理--同步锁 #递归锁 #队列，线程间数据的安全 #生产者消费者模型 ...
分类：
编程语言 时间：
2019-10-21 10:02:25
阅读次数：
82
sem mutex1=1; sem mutex2=1; sem empty=1000; sem full=0; producer() { while(1) { 生产一个产品 p(empty); p(mutex2); 放入缓冲区 v(mutex2); v(full); } } consumer() {... ...
分类：
其他好文 时间：
2019-10-20 20:08:19
阅读次数：
80
一、什么是生产者消费者模型 生产者消费者模型就是通过一个容器解决它们之间的强耦合问题，生产者与消费者之间依靠阻塞队列进行通讯，生产者与消费者之间不直接通讯，这样平衡了二者之间的处理能力，这里使用了进程、线程以及生成器实现了生产者消费者模型。 在进程中分别开启了生产者和消费者的进程，它们之间的通讯依赖 ...
分类：
其他好文 时间：
2019-10-16 21:34:45
阅读次数：
83
什么是阻塞队列?如何使用阻塞队列来实现生产者-消费者模型?java.util.concurrent.BlockingQueue的特性是：当队列是空的时，从队列中获取或删除元素的操作将会被阻塞，或者当队列是满时，往队列里添加元素的操作会被阻塞。阻塞队列不接受空值，当你尝试向队列中添加空值的时候，它会抛出NullPointerException。阻塞队列的实现都是线程安全的，所有的查询方法都是原子的并
分类：
其他好文 时间：
2019-10-15 10:06:45
阅读次数：
96
一 生产者消费者模型介绍 为什么要使用生产者消费者模型 生产者指的是生产数据的任务，消费者指的是处理数据的任务，在并发编程中，如果生产者处理速度很快，而消费者处理速度很慢，那么生产者就必须等待消费者处理完，才能继续生产数据。同样的道理，如果消费者的处理能力大于生产者，那么消费者就必须等待生产者。为了 ...
分类：
其他好文 时间：
2019-10-13 11:03:17
阅读次数：
70
