类 net.neoremind.fountain.common.mq.AbstractMaxCapacityFountainMQ
的使用

使用 AbstractMaxCapacityFountainMQ 的软件包
net.neoremind.fountain.common.mq   
 

net.neoremind.fountain.common.mq 中 AbstractMaxCapacityFountainMQ 的使用
 

net.neoremind.fountain.common.mq 中 AbstractMaxCapacityFountainMQ 的子类
 class MemFountainMQ
          FountainMQ缺省实现,每个放入队列的对象 占用队列容量数为1

封装BlockingQueue,必须有界,这是为了防止内存oom

 class MultiPermitsMemFountainMQ
          每个数据消息占用多个队列容量的队列。
 



Copyright © 2016 neoremind. All rights reserved.