1 Producer-Consumer PatternProducer-Consumer Pattern主要就是在生产者与消费者之间建立一个“桥梁参与者”，用来解决生产者线程与消费者线程之间速度的不匹配。 当要从某个线程Produccer参与者将数据传输给其它线程Consumer参与者的时候，此时就...
分类：
编程语言 时间：
2015-01-04 19:16:06
阅读次数：
242
生产者消费者的问题 String 类适用于描述字符串事物。那么他就提供了多个方法对字符串进行操作。常见的操作有哪些？1，获取 1.1字符串的长度 int length(); 1.2获取某个位置上的字符 char chaeAt(int index) 1.3 根据字符获取该字符在字符串中的位置。int ...
分类：
其他好文 时间：
2015-01-02 15:50:03
阅读次数：
161
第一个程序是数据生产者程序。它在需要时创建管道，然后尽可能快地向管道中写入数据。为了方便起见，本程序没有初始化缓冲区。
生产者程序
/*数据生产者*/
#include
#include
#include
#include
#include
#include
#include
#include
#define FIFO_NAME "/tmp/my_fifo"
#defin...
分类：
系统相关 时间：
2015-01-01 17:24:25
阅读次数：
301
从AMQP协议可以看出，MessageQueue、Exchange和Binding构成了AMQP协议的核心。下面我们就围绕这三个主要组件，从应用使用的角度全面的介绍如何利用RabbitMQ构建消息队列以及使用过程中的注意事项。声明MessageQueue: 在RabbitMQ中，无论是生产者发送.....
分类：
其他好文 时间：
2014-12-30 18:44:57
阅读次数：
221
1 应用背景： 需要实时统计用户的登陆数，在线人数，活跃时间，下载等指标的数据，或者清洗后移到hdfs上。
2 设计架构：
1） 客户端产生数据---
2） kafka-生产者实时采集数据（保留7天）-----
3） storm实时消费数据，处理数据
4）把实时数据统计结果缓存到memcached 中...
分类：
其他好文 时间：
2014-12-29 23:01:45
阅读次数：
235
之前用C++写过一篇生产者消费者的实现。 生产者和消费者主要是处理互斥和同步的问题： 队列作为缓冲区，需要互斥操作 队列中没有产品，消费者需要等待，直到生产者放入产品并通知它。队列慢的情况类似。 这里我使用list模拟Python标准库的Queue，这里我设置一个大小限制为5： SyncQueue....
分类：
编程语言 时间：
2014-12-28 15:25:18
阅读次数：
226
生产者消费者问题
（英语：Producer-consumer
problem），也称有限缓冲问题（英语：Bounded-buffer
problem），是一个多线程同步问题的经典案例。该问题描述了两个共享固定大小缓冲区的线程——即所谓的“生产者”和“消费者”——在实际运行时会发生的问题。生产者的主要作用是生成一定量的数据放到缓冲区中，然后重复此过程。与此同时，消费者也在缓冲区消耗这...
分类：
数据库 时间：
2014-12-27 00:21:38
阅读次数：
246
【版权声明：尊重原创，转载请保留出处：blog.csdn.net/shallnet 或 .../gentleliu，文章仅供学习交流，请勿用于商业用途】
在第一节说到了生产者消费者问题，这一节我们来实现这样一个稍作修改的模型： 初始时缓冲区为空，生产者向缓冲区写入数据，消费者在缓冲区为空的情况下睡眠，当生产者写满缓冲区一半之后后通知消费者可以开始消费，生产者开始睡眠，直到消费者消...
分类：
编程语言 时间：
2014-12-23 17:32:51
阅读次数：
225
消息通知
任务队列
使用任务队列的好处
松耦合。生产者和消费者无需知道彼此的实现细节，只需要约定好任务的描述格式。这使得生产者和消费者可以由不同的团队使用不同的编程语言编写易于扩展。消费者可以有多个，而且可以分布在不同的服务器中, 借此可以轻易地降低单台服务器的负载
使用LPUSH和RPOP命令实现队列, 这里介绍一个新命令BRPOP和BLPOP BRPOP key...
分类：
其他好文 时间：
2014-12-23 10:35:50
阅读次数：
218
JAVA里也有强大的信号量工具Semaphore，使用信号量可以很方便的实现线程同步功能，以解决类似于 生产者——消费者 之类的典型问题。下面是我的测试程序，大部分看注释就可以明白用法：import java.util.LinkedList;import java.util.Queue;import...
分类：
编程语言 时间：
2014-12-18 11:53:38
阅读次数：
191
