生产者和消费者同时工作：生产者1s生产一次，消费者5s消费一次生产者5s生产一次，消费者1s消费一次这样的话效率很低，就好像我去商店买西瓜，超市里西瓜卖完了，我每过一小时去看一次有没有新来的西瓜。如果我把手机号码留给老板，西瓜到了让老板通知我，这样效率就高了。看下..
分类：
其他好文 时间：
2016-09-16 21:23:09
阅读次数：
173
死锁发生的情况：上述代码中，把标色的this.notifyAll();改为this.notify();就会发生线程的死锁，为什么呢？应为代码中总共有4个线程，生产者1和生产者2，消费者1和消费者2。理想状态是生产者1和生产者2执行生产操作，消费者1和消费者2执行消费操作，生产一个，消费一个。现在线程 ...
分类：
编程语言 时间：
2016-09-16 11:26:56
阅读次数：
147
摘要 Message Queue消息队列，简称MQ，是一种应用程序对应用程序的通信方法，应用程序通过读写出入队列的消息来通信，而无需专用连接来链接它们。消息传递指的是程序之间通过在消息中发送数据进行通信，而不是通过直接调用彼此通信。 MQ是消费-生产者模型的一个典型代表，一端往消息队列中不断写入消息 ...
引言 生产者和消费者问题是线程模型中的经典问题：生产者和消费者在同一时间段内共用同一个存储空间，如下图所示，生产者向空间里存放数据，而消费者取用数据，如果不加以协调可能会出现以下情况： 生产者消费者图 存储空间已满，而生产者占用着它，消费者等着生产者让出空间从而去除产品，生产者等着消费者消费产品，从 ...
分类：
编程语言 时间：
2016-09-11 20:05:38
阅读次数：
142
生产者——消费者模型中，生产者和消费者线程之间需要传递一定量的数据，两个线程会使用一个特定大小的共享环形缓冲器。生产者向缓冲器中写入数据，直到它到达缓冲器的终点；然后它会再次从起点重新开始，覆盖已经存在的数据。消费者线程则会读取生成的数据。在生产者——消费..
分类：
其他好文 时间：
2016-09-11 15:45:02
阅读次数：
212
这是一个反序列化的过程，也就是对象数据流转换为一个实例的过程，其运行后的输出结果为“混世魔王”。这太easy了,是的，这就是序列化和反序列化的典型Demo。但此处藏着一个问题：如果消息的生产者和消息的消费者（Person类）有差异，会出现何种神奇事件呢？比如：消息生产者中的Person类添加一个年龄... ...
分类：
其他好文 时间：
2016-09-10 17:43:44
阅读次数：
187
Linux下librdkafka客户端的编译运行 librdkafka是一个开源的Kafka客户端C/C++实现，提供了Kafka生产者、消费者接口。 由于项目需要，我要将Kafka生产者接口封装起来给别人调用，所以先安装了librdkakfa，然后在demo上进行修改封装一个生产者接口。 [一] ...
分类：
系统相关 时间：
2016-09-09 11:44:20
阅读次数：
8180
global 全局，全球priority 优先load 平衡 balance 负载 cluster 集群subscribe 订阅filter 过滤，滤除，滤波器producer 生产者consume 消费者payload 有效负载merge 合并reject 拒绝declare 声明。宣布guard ...
分类：
其他好文 时间：
2016-09-08 16:14:26
阅读次数：
141
在本人的上一篇博客文章：Netty构建分布式消息队列（AvatarMQ）设计指南之架构篇 中，重点向大家介绍了AvatarMQ主要构成模块以及目前存在的优缺点。最后以一个生产者、消费者传递消息的例子，具体演示了AvatarMQ所具备的基本消息路由功能。而本文的写作目的，是想从开发、设计的角度，简单的 ...
分类：
Web程序 时间：
2016-09-07 09:15:22
阅读次数：
323
一. 生产者/消费者模式 概念：生产者产生一块数据，放到buffer中，与此同时，消费者在从buffer中取出并消耗这些数据 理解：像生活中厂家生产出产品，顾客购买消耗这些产品，buffer就是存放商品的仓库。 二. 生产者/消费者模式在python中的实现 相关模块：Queue模块 简单介绍：Py ...
分类：
编程语言 时间：
2016-09-05 20:53:24
阅读次数：
152
