我们经常会遇到生产者消费者模式，比如前端各种UI操作事件触发后台逻辑等。在这种典型的应用场景中，我们可能会有4个业务处理逻辑（下文以P代表生产者，C代表消费者）： 1. FIFO（先进先出） P产生1,2,3,4,5,6,3,2 C处理顺序应为1,2,3,4,5,6,3,2 2.LIFO(后进先出）...
分类：
其他好文 时间：
2015-05-30 17:51:10
阅读次数：
152
Thread类基本信息方法
线程同步
由于同一进程的多个线程共享同一片存储空间，在带来方便的同时，也带来了访问冲突这个严重的问题。Java语言提供了专门机制以解决这种冲突，有效避免了同一个数据对象被多个线程同时访问。由于我们可以通过private关键字来保证数据对象只能被方法访问，所以我们只需针对方法提出一套机制，这套机制就是synchronized关键字，它包括两种用法：synchr...
分类：
编程语言 时间：
2015-05-28 21:37:02
阅读次数：
215
java线程中断[interrupt()函数]http://vikings825.iteye.com/blog/964644聊聊并发——生产者消费者模式http://www.infoq.com/cn/articles/producers-and-consumers-mode/
分类：
编程语言 时间：
2015-05-27 21:02:54
阅读次数：
153
同步：共享资源被多个线程 调用，同步的方式有多种：（场景：卖火车票） 1 syncnizerd 关键字 2 reentrantLock 排它锁 3 volatile 关键字 修饰变量；异步：改变线程本身的状态 ，异步方法有多种：（场景：生产者消费者模式） 1 wait notify ，Object ...
分类：
编程语言 时间：
2015-05-27 18:47:31
阅读次数：
175
ActiveMQ支持两种模式：Queue模式和Topic模式
1、Queue模式（P2P模式）
生产者发送消息，消费者介绍消息。
队列采用FIFO策略。
当一个Queue有多个消费者时，消费者按照先后顺序排队，队首的消费者从Queue首接收一条消息后从队首位置返回队尾位置重新进行排队。比如一个生产者发送了编号为1-5的消息，假设该Queue有两个消费者分别命名为c1和c2，c1在前、c...
分类：
其他好文 时间：
2015-05-27 12:17:02
阅读次数：
793
NSCondition用法使用NSCondition，实现多线程同步。。。举个列子 消费者跟生产者。。。现在传言6s要出了。。消费者想买6s。现在还没有6s。消费者等待6s生产。生产了一个产品，唤起消费者去买6s。解锁 1 @interface ViewController () 2 /* 3 创....
分类：
其他好文 时间：
2015-05-27 11:43:25
阅读次数：
207
生产者与消费者： 1 public class ProducerConsumer { 2 public static void main(String[] args) { 3 Basket bs=new Basket(); 4 Producer p=new P...
分类：
编程语言 时间：
2015-05-26 18:02:23
阅读次数：
185
目录宏观上的“系统架构”系统架构图（举例）微观上的系统设计生产者-消费者 设计图（举例）宏观架构与微观设计的区别孰轻孰重？三种线程泵的作用代码中泵的作用常见泵结构（1）常见泵结构（2）常见泵结构（3）常见泵结构（4）常见泵结构（5）串行处理数据的泵并行处理数据的泵泵对于系统的意义什么是框架？框架的特...
分类：
其他好文 时间：
2015-05-25 20:13:46
阅读次数：
170
1.ProducerRecord 含义:发送给Kafka Broker的key/value值对2.内部数据结构：-- Topic（名字）-- PartitionID (可选)-- Key[(可选)-- Value3.生产者记录（简称PR）的发送逻辑: 若指定Partition ID,则PR被发送至指...
分类：
其他好文 时间：
2015-05-25 18:07:47
阅读次数：
208
创建一个Kafka的主题，连接到zk集群，副本因子3，分区3，主题名是test111 [root@h5 kafka]# bin/kafka-topics.sh --create --zookeeper h5:2181 --topic test111 --replication-factor 3 .....
分类：
编程语言 时间：
2015-05-24 17:20:41
阅读次数：
3423
