生产者
import java.util.Properties;
import kafka.javaapi.producer.Producer;
import kafka.producer.KeyedMessage;
import kafka.producer.ProducerConfig;
import kafka.serializer.StringEncoder;
...
zbus https://git.oschina.net/rushmore/zbus 轻量级服务总线/消息队列 1）多种消息模式--支持生产者/消费者，发布订阅，RPC 2）丰富的API--C/C++/C#/JAVA/Python/Node.JS跨平台、多语言支持 3）开放协议标准--原...
分类：
其他好文 时间：
2015-07-29 23:14:42
阅读次数：
717
BlockingQueue、BoundedBlockingQueue是关于有界缓冲和无界缓冲的，是典型的生产者消费者模型的代表。...
分类：
数据库 时间：
2015-07-29 17:24:26
阅读次数：
248
线程同步-条件变量
生产者与消费者问题
再引入条件变量之前，我们先看下生产者和消费者问题：生产者不断地生产产品，同时消费者不断地在消费产品。
这个问题的同步在于两处：第一，消费者之间需要同步：同一件产品只可由一人消费。第二，当无产品可消费时，消费者需等待生产者生产后，才可继续消费，这又是一个同步问题。详细了解：生产者消费者问题。
条件变量
条件变量是利用线程间共享的全局变量进行同步的一种机制，并且条件变量总是和互斥锁结合在一起。
相关函数...
分类：
编程语言 时间：
2015-07-26 12:46:01
阅读次数：
518
我们常用wait()，notify()和notifyAll()方法来进行线程间通信。线程检查一个条件后就行进入等待状态，例如，在“生产者-消费者”模型中，生产者线程发现缓冲区满了就等待，消费者线程通过消费一个产品使得缓冲区有空闲并通知生产者线程。notify()或notifyAll()的调用给一个或多个线程发出通知，告诉它（它们）条件已经发生改变，并且，一旦通知线程离开同步块，所有等待这个对象锁的...
分类：
其他好文 时间：
2015-07-26 00:35:34
阅读次数：
3183
1 package ThreadL; 2 3 import java.util.LinkedList; 4 5 class Queue extends LinkedList{ 6 int lenght; 7 public Queue(){ 8 ...
分类：
其他好文 时间：
2015-07-25 19:49:37
阅读次数：
104
在操作系统中有一类问题被称为生产者消费者问题：意为，有数个生产者生产产品，有数个消费者消费产品，他们共享一定数量的缓存。这里用java多线程编程，实现生产者消费者问题的一种延伸，橘子苹果问题。题目如下：有苹果橘子生产者各20个，有苹果橘子消费者各20个，他们公用20个缓存区。要求能随时查看缓存区内容...
分类：
编程语言 时间：
2015-07-19 23:05:57
阅读次数：
152
生产者消费者问题（Producer-consumer problem）是一个多线程同步问题的经典案例。该问题描述了两个共享固定大小缓冲区的线程——即所谓的“生产者”和“消费者”——在实际运行时会发生的问题。生产者的主要作用是生成一定量的数据放到缓冲区中，然后重复此过程。与此同时，消费者也在缓冲区消耗这些数据。该问题的关键就是要保证生产者不会在缓冲区满时加入数据，消费者也不会在缓冲区中空时消耗数据。什...
分类：
其他好文 时间：
2015-07-19 10:16:12
阅读次数：
179
学习Java的多线程，生产者消费者模式是避免不了的。下面将以wait/notify,await/singal,blockingquene几种方式来实现生产者消费者模式。 使用wait/notify先了解以下知识： 每一个同步锁lock下面都挂了几个线程队列，包括就绪（Ready）队列，等待（...
分类：
其他好文 时间：
2015-07-18 18:34:37
阅读次数：
185
转载自http://www.cnblogs.com/happyPawpaw/archive/2013/01/18/2865957.html引言 生产者和消费者问题是线程模型中的经典问题：生产者和消费者在同一时间段内共用同一个存储空间，如下图所示，生产者向空间里存放数据，而消费者取用数据，如果不加以....
分类：
编程语言 时间：
2015-07-16 02:05:27
阅读次数：
176
