|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
| Packages that use QueueConsumer | |
|---|---|
| net.sf.jabb.util.thread | |
| Uses of QueueConsumer in net.sf.jabb.util.thread |
|---|
| Subclasses of QueueConsumer in net.sf.jabb.util.thread | |
|---|---|
class |
QueueBatchUniqueProcessor<E>
A template for processing data in batch from a queue. 一个从队列中取得数据并批量处理的模板,数据一批批被取走并处理。 |
class |
QueueProcessor<E>
A template for processing data one by one from a queue. 一个从队列中逐个取得数据进行处理的模板,数据一个一个被取走并处理。 |
| Fields in net.sf.jabb.util.thread with type parameters of type QueueConsumer | |
|---|---|
protected Map<String,QueueConsumer<E>> |
QueueConsumerGroup.consumers
|
| Methods in net.sf.jabb.util.thread that return QueueConsumer | |
|---|---|
QueueConsumer<E> |
QueueConsumerGroup.getConsumer(String name)
Get QueueConsumer instance by its name. 按名称寻找得到QueueConsumer。 |
| Methods in net.sf.jabb.util.thread that return types with arguments of type QueueConsumer | |
|---|---|
Map<String,QueueConsumer<E>> |
QueueConsumerGroup.getConsumers()
Get the Map of all QueueConsumer. 获得含有全部QueueConsumer的Map。 |
| Constructors in net.sf.jabb.util.thread with parameters of type QueueConsumer | |
|---|---|
QueueConsumerGroup(BlockingQueue<E> workQueue,
ExecutorService executorService,
QueueConsumer<E>... queueConsumers)
Constructor, specifying one thread pool for all QueueConsumers to use. 创建实例,让所有的QueueConsumer统一使用指定的线程池。 |
|
QueueConsumerGroup(BlockingQueue<E> workQueue,
QueueConsumer<E>... queueConsumers)
Constructor, without specifying thread pool. 创建实例,不指定统一的线程池。 |
|
QueueConsumerGroup(int workQueueSize,
ExecutorService executorService,
QueueConsumer<E>... queueConsumers)
Constructor, specifying one thread pool for all QueueConsumers to use. 创建实例,让所有的QueueConsumer统一使用指定的线程池。 |
|
QueueConsumerGroup(int workQueueSize,
QueueConsumer<E>... queueConsumers)
Constructor, without specifying thread pool. 创建实例,不指定统一的线程池。 |
|
| Constructor parameters in net.sf.jabb.util.thread with type arguments of type QueueConsumer | |
|---|---|
QueueConsumerGroup(BlockingQueue<E> workQueue,
Collection<? extends QueueConsumer<E>> queueConsumers)
Constructor, without specifying thread pool. 创建实例,不指定统一的线程池。 |
|
QueueConsumerGroup(BlockingQueue<E> workQueue,
ExecutorService executorService,
Collection<? extends QueueConsumer<E>> queueConsumers)
Constructor, specifying one thread pool for all QueueConsumers to use. 创建实例,让所有的QueueConsumer统一使用指定的线程池。 |
|
QueueConsumerGroup(int workQueueSize,
Collection<? extends QueueConsumer<E>> queueConsumers)
Constructor, without specifying thread pool. 创建实例,不指定统一的线程池。 |
|
QueueConsumerGroup(int workQueueSize,
ExecutorService executorService,
Collection<? extends QueueConsumer<E>> queueConsumers)
Constructor, specifying one thread pool for all QueueConsumers to use. 创建实例,让所有的QueueConsumer统一使用指定的线程池。 |
|
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||