Package | Description |
---|---|
net.sf.jabb.util.thread |
Modifier and Type | Class and Description |
---|---|
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.
一个从队列中逐个取得数据进行处理的模板,数据一个一个被取走并处理。 |
Modifier and Type | Field and Description |
---|---|
protected Map<String,QueueConsumer<E>> |
QueueConsumerGroup.consumers |
Modifier and Type | Method and Description |
---|---|
QueueConsumer<E> |
QueueConsumerGroup.getConsumer(String name)
Get QueueConsumer instance by its name.
按名称寻找得到QueueConsumer。 |
Modifier and Type | Method and Description |
---|---|
Map<String,QueueConsumer<E>> |
QueueConsumerGroup.getConsumers()
Get the Map of all QueueConsumer.
获得含有全部QueueConsumer的Map。 |
Constructor and Description |
---|
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 and Description |
---|
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统一使用指定的线程池。 |
Copyright © 2014. All Rights Reserved.