org.nanoframework.concurrent.queue

类 BlockingQueueFactory

java.lang.Object

org.nanoframework.concurrent.queue.BlockingQueueFactory

public class BlockingQueueFactory
extends Object

阻塞队列工厂类.

从以下版本开始:

1.0

作者:

yanghe

字段概要

字段

限定符和类型	字段和说明
static int	DEFAULT_QUEUE_SIZE

方法概要

限定符和类型	方法和说明
static BlockingQueueFactory	getInstance()
BlockingQueue<Object>	getQueue(String key) 根据Key获取阻塞队列
static int	howManyElementInQueues()
void	initQueue(String key) 初始化队列
void	initQueue(String key, int size) 初始化队列
boolean	offer(String key, Object bean) 向队列中添加元素
boolean	offer(String key, Object bean, Long time, TimeUnit unit) 在设定时间内向队列中添加元素，超时抛出中断异常
<T> T	poll(String key) 从队列中获取元素
<T> List<T>	poll(String key, int size, long time, TimeUnit unit)
<T> T	poll(String key, Long time, TimeUnit unit) 在设定时间内从队列中获取元素，超时抛出中断异常
void	put(String key, Object bean) 向队列中添加元素
void	setQueue(String key, ArrayBlockingQueue<Object> queue) 向工厂中添加队列
Object	take(String key) 从队列中获取元素

从类继承的方法 java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

DEFAULT_QUEUE_SIZE

public static final int DEFAULT_QUEUE_SIZE

另请参阅:

常量字段值

方法详细资料

getInstance

public static BlockingQueueFactory getInstance()

getQueue

public BlockingQueue<Object> getQueue(String key)
                               throws RuntimeException

根据Key获取阻塞队列

参数:

key - 队列Key

返回:

返回阻塞队列

抛出:

RuntimeException - 运行时异常

initQueue

public void initQueue(String key,
                      int size)

初始化队列

参数:

key - 队列Key

size - 队列大小

initQueue

public void initQueue(String key)

初始化队列

参数:

key - 队列Key

setQueue

public void setQueue(String key,
                     ArrayBlockingQueue<Object> queue)

向工厂中添加队列

参数:

key - 队列Key

queue - 队列

put

public void put(String key,
                Object bean)
         throws InterruptedException

向队列中添加元素

参数:

key - 队列Key

bean - 对象

抛出:

InterruptedException - 中断异常

take

public Object take(String key)
            throws InterruptedException

从队列中获取元素

参数:

key - 队列Key

返回:

返回对象

抛出:

InterruptedException - 中断异常

offer

public boolean offer(String key,
                     Object bean)

向队列中添加元素

参数:

key - 队列Key

bean - 对象

返回:

返回添加结果

offer

public boolean offer(String key,
                     Object bean,
                     Long time,
                     TimeUnit unit)
              throws InterruptedException

在设定时间内向队列中添加元素，超时抛出中断异常

参数:

key - 队列Key

bean - 对象

time - 超时时间

unit - 时间类型

返回:

返回添加结果

抛出:

InterruptedException - 中断异常

poll

public <T> T poll(String key)

从队列中获取元素

类型参数:

T - the value type

参数:

key - 队列key

返回:

T

poll

public <T> T poll(String key,
                  Long time,
                  TimeUnit unit)
           throws InterruptedException

在设定时间内从队列中获取元素，超时抛出中断异常

类型参数:

T - the value type

参数:

key - 队列Key

time - 超时时间

unit - 时间类型

返回:

返回队列元素

抛出:

InterruptedException - 中断异常

poll

public <T> List<T> poll(String key,
                        int size,
                        long time,
                        TimeUnit unit)

howManyElementInQueues

public static final int howManyElementInQueues()