package j2se.thread.demo;/** * Project:J2SE 的基础知识 * Tile:多线程模拟 生产者 和 消费者 * Description: * * * * * @date 2014-06-10 * @author liw...
分类：
编程语言 时间：
2014-10-01 21:11:41
阅读次数：
206
最近用C++写安卓下的一个通讯程序，作为jni库给java调用，采用多线程轮询遇到一个问题描述如下：
A线程收到数据，放入队列，是生产者。
B、C、D若干个线轮询训消息队列，如果队列有数据就取出进行处理，没数据就Sleep(T)休息，问题是这个T值取多大合适？取大了消息处理不及时，取小了手机cpu上升电池很快耗光。
这个问题最佳解法是采用条件变量，可以比较完美解决问题...
分类：
编程语言 时间：
2014-09-29 22:17:21
阅读次数：
233
kafka概念：
kafka是一个高吞吐量的流式分布式消息系统，用来处理活动流数据，比如网页的访问量pm,日志等，既能够实时处理大数据信息
也能离线处理。
特点：
1.高吞吐量
2.是一种显式的分布式系统，它假设，数据生产者（producer）,代理（brokers）和数据使用者（consum...
分类：
其他好文 时间：
2014-09-29 20:09:12
阅读次数：
196
因为node使用单线程的方式实现，所以，在此使用定时器timer取代线程thread来实现生产者消费者模型。代码例如以下：var sigintCount = 0;var productArray = [];var productArrayLen = 0;var productLock = false...
分类：
Web程序 时间：
2014-09-28 20:13:45
阅读次数：
204
生产者消费者模型已是很经典的并行模型了，百度了下发现资料尚少，故作此篇，望能有受益人～...
分类：
其他好文 时间：
2014-09-26 23:19:59
阅读次数：
314
Java并发编程实践 目录并发编程—— ConcurrentHashMap并发编程—— 阻塞队列和生产者-消费者模式并发编程—— 闭锁CountDownLatch 与 栅栏CyclicBarrier并发编程—— Callable和Future并发编程—— CompletionService : Ex...
分类：
其他好文 时间：
2014-09-26 13:45:58
阅读次数：
220
Java并发编程实践 目录并发编程—— ConcurrentHashMap并发编程—— 阻塞队列和生产者-消费者模式并发编程—— 闭锁CountDownLatch 与 栅栏CyclicBarrier并发编程—— Callable和Future并发编程—— CompletionService : Ex...
分类：
其他好文 时间：
2014-09-25 20:36:17
阅读次数：
143
同步代码块实现生产者消费者模式class Person { private String name; private String sex; private Boolean isEmpty = Boolean.TRUE; // 表示存储区域是否为空 //生产 publi...
分类：
编程语言 时间：
2014-09-25 17:31:49
阅读次数：
331
在多线程中，两个线程之间交换数据是非常常见的情况，我们可以使用公共的数据结构，同样，Java也提供了很好
的类供我们使用，那就是Exchanger类，这个类可以帮助我们在两个线程之间同步数据结构，下面我们以这个类再来实
现一遍生产者消费者模型，貌似这个模型已经被写烂了。
package com.bird.concursey.charpet5;
import java.util.Li...
分类：
编程语言 时间：
2014-09-23 23:21:55
阅读次数：
368
