Condition的功能类似在传统线程技术中的Object.wait和Object.notity的功能。例子：生产者与消费者import java.util.Random;import java.util.concurrent.ExecutorService;import java.util.con...
分类：
其他好文 时间：
2015-12-11 22:26:27
阅读次数：
234
package cn.itcast.thread;/*线程通讯： 一个A线程完成了当前的任务时，要通知另外B线程去做另外事情。生产者与消费者。问题一：价格错乱问题。(线程安全问题) 问题： 目前要不就是生成一大批的产品，要不消费一大批的产品要求的效果： 生产一个消费一个。线程通讯相关方法： wait...
分类：
编程语言 时间：
2015-12-10 13:06:56
阅读次数：
149
第六章任务执行6.1在线程中执行任务串行-》多线程-》有限个多线程6.2executor框架通过有界队列可以防止高负荷程序过度消耗内存java.lang.concurrent提供了线程池作为实现executor框架的一部分executor接口：提供生产者-消费者模式基于executor的web服务器：publicclassTaskExec..
分类：
编程语言 时间：
2015-12-08 07:20:21
阅读次数：
202
本文描述了在Android系统，如果使用异步任务，并且通过消息总线机制，实现消息生产者和消费者的松耦合，同时更高效处理多线程情况。...
分类：
移动开发 时间：
2015-12-04 14:54:26
阅读次数：
168
Todo:对Flume的sink进行重构，调用kafka的消费生产者(producer)发送消息;在Sotrm的spout中继承IRichSpout接口，调用kafka的消息消费者(Consumer)来接收消息，然后经过几个自定义的Bolt，将自定义的内容进行输出编写KafkaSink从$KAFKA...
分类：
Web程序 时间：
2015-11-27 17:43:28
阅读次数：
290
1:多线程(理解) (1)JDK5以后的针对线程的锁定操作和释放操作 Lock锁 (2)死锁问题的描述和代码体现 (3)生产者和消费者多线程体现(线程间通信问题) 以学生作为资源来实现的 资源类：Student 设置数据类：SetThread(生产者) 获取数据类：GetThread(...
分类：
编程语言 时间：
2015-11-26 12:59:12
阅读次数：
140
转：http://blog.csdn.net/m13321169565/article/details/8081358在Activemq以前的版本中，broker会把待发送的消息保存在内存中。这种方式的缺陷是当消费者消费的速度赶不上生产者的速度时，会在broker的内存中积攒大量的消息，当达到一个限...
分类：
其他好文 时间：
2015-11-21 23:59:30
阅读次数：
389
欢迎访问：鲁春利的工作笔记，学习是一种信仰，让时间考验坚持的力量。Kafka底层是基于Scala语言实现的，但是也提供了Java的API接口。Java实现的消息生产者packagecom.lucl.kafka.simple;
importjava.util.Properties;
importkafka.javaapi.producer.Producer;
importkafka.p..
分类：
编程语言 时间：
2015-11-20 00:18:40
阅读次数：
382
在前面我们接触的队列都是非阻塞队列，比如PriorityQueue、LinkedList（LinkedList是双向链表，它实现了Dequeue接口）。 使用非阻塞队列的时候有一个很大问题就是：它不会对当前线程产生阻塞，那么在面对类似消费者-生产者的模型时，就必须额外地实现同步策略以及线程间唤醒策....
分类：
其他好文 时间：
2015-11-19 22:10:40
阅读次数：
172
