CTPBlockQueue

java.lang.Object
- com.seeyon.ctp.common.queue.AbstractCTPQueue<E>
- - com.seeyon.ctp.common.queue.CTPBlockQueue<E>

类型参数:

E -

所有已实现的接口:

java.lang.Iterable<E>, java.util.Collection<E>, java.util.Queue<E>
```
public class CTPBlockQueue<E>
extends AbstractCTPQueue<E>
```
阻塞队列，可以手工设置长度，不设置那就是无边际的队列

字段概要

字段
限定符和类型字段和说明

java.util.concurrent.LinkedBlockingQueue<Node<E>> queue

字段
限定符和类型	字段和说明
`java.util.concurrent.LinkedBlockingQueue<Node<E>>`	`queue`

构造器概要

构造器
构造器和说明

CTPBlockQueue()

CTPBlockQueue(int capacity)

构造器
构造器和说明
`CTPBlockQueue()`
`CTPBlockQueue(int capacity)`

方法概要

所有方法实例方法具体方法
限定符和类型	方法和说明
`void`	`clear()`
`protected boolean`	`containsAllNodes(java.util.Collection<?> c)`
`protected boolean`	`containsNode(Node<java.lang.Object> o)`
`protected java.util.Iterator<Node<E>>`	`getIterator()` 获取实现队列的迭代器
`boolean`	`isEmpty()`
`boolean`	`offer(E e, long timeout, java.util.concurrent.TimeUnit unit)` 将元素e插入到队列末尾，如果插入成功，则返回true；队列已满，阻塞等待
`protected boolean`	`offerNode(Node<E> node)` 将元素e插入到队列末尾，如果插入成功，则返回true；如果插入失败（即队列已满），则返回false；接口方法 offer的具体实现，由各自的队列实现类实现
`protected Node<E>`	`peekNode()` 返回队列头部的元素 ,如果队列为空，则返回null 接口方法 peek的具体实现，由各自的队列实现类实现
`E`	`poll(long timeout, java.util.concurrent.TimeUnit unit)` 移除并获取队首元素，若成功，则返回队首元素；队列无数据，阻塞等待
`protected Node<E>`	`pollNode()` 移除并获取队首元素，若成功，则返回队首元素；否则返回null 接口方法 poll的具体实现，由各自的队列实现类实现
`void`	`put(E e)` 存入元素，队列已满，阻塞等待
`protected boolean`	`removeAllNodes(java.util.Collection<?> c)`
`protected boolean`	`removeNode(Node<java.lang.Object> o)`
`protected boolean`	`retainAllNodes(java.util.Collection<?> c)`
`int`	`size()`
`E`	`take()` 去数据，当队列为空时阻塞

从类继承的方法 com.seeyon.ctp.common.queue.AbstractCTPQueue
add, addAll, contains, containsAll, element, iterator, offer, peek, poll, remove, remove, removeAll, retainAll, toArray, toArray

从类继承的方法 java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

从接口继承的方法 java.util.Collection
equals, hashCode, parallelStream, removeIf, spliterator, stream

从接口继承的方法 java.lang.Iterable
forEach

- 字段详细资料
  - queue
```
public java.util.concurrent.LinkedBlockingQueue<Node<E>> queue
```
- 构造器详细资料
  - CTPBlockQueue
```
public CTPBlockQueue()
```
  - CTPBlockQueue
```
public CTPBlockQueue(int capacity)
```
    参数:
    
    capacity - 阻塞队列的大小，默认为Integer.MAX_VALUE
- 方法详细资料
  - size
```
public int size()
```
  - isEmpty
```
public boolean isEmpty()
```
  - clear
```
public void clear()
```
  - offer
```
public boolean offer(E e,
                     long timeout,
                     java.util.concurrent.TimeUnit unit)
              throws java.lang.InterruptedException
```
    将元素e插入到队列末尾，如果插入成功，则返回true；队列已满，阻塞等待
    
    参数:
    
    e -
    
    timeout - 超时时间
    
    unit - 单位
    
    返回:
    
    抛出:
    
    java.lang.InterruptedException
  - offerNode
```
protected boolean offerNode(Node<E> node)
```
    从类复制的说明: AbstractCTPQueue
    
    将元素e插入到队列末尾，如果插入成功，则返回true；如果插入失败（即队列已满），则返回false；接口方法 offer的具体实现，由各自的队列实现类实现
    
    指定者:
    
    offerNode 在类中 AbstractCTPQueue<E>
    
    参数:
    
    node - 封装了租户id和实际队列对象的对象
    
    返回:
  - poll
```
public E poll(long timeout,
              java.util.concurrent.TimeUnit unit)
       throws java.lang.InterruptedException
```
    移除并获取队首元素，若成功，则返回队首元素；队列无数据，阻塞等待
    
    参数:
    
    timeout - 超时时间
    
    unit - 单位
    
    返回:
    
    抛出:
    
    java.lang.InterruptedException
  - take
```
public E take()
       throws java.lang.InterruptedException
```
    去数据，当队列为空时阻塞
    
    返回:
    
    抛出:
    
    java.lang.InterruptedException
  - put
```
public void put(E e)
         throws java.lang.InterruptedException
```
    存入元素，队列已满，阻塞等待
    
    参数:
    
    e -
    
    抛出:
    
    java.lang.InterruptedException
  - pollNode
```
protected Node<E> pollNode()
```
    从类复制的说明: AbstractCTPQueue
    
    移除并获取队首元素，若成功，则返回队首元素；否则返回null 接口方法 poll的具体实现，由各自的队列实现类实现
    
    指定者:
    
    pollNode 在类中 AbstractCTPQueue<E>
    
    返回:
    
    node 封装了租户id和实际队列对象的对象
  - peekNode
```
protected Node<E> peekNode()
```
    从类复制的说明: AbstractCTPQueue
    
    返回队列头部的元素 ,如果队列为空，则返回null 接口方法 peek的具体实现，由各自的队列实现类实现
    
    指定者:
    
    peekNode 在类中 AbstractCTPQueue<E>
    
    返回:
    
    node 封装了租户id和实际队列对象的对象
  - getIterator
```
protected java.util.Iterator<Node<E>> getIterator()
```
    从类复制的说明: AbstractCTPQueue
    
    获取实现队列的迭代器
    
    指定者:
    
    getIterator 在类中 AbstractCTPQueue<E>
    
    返回:
  - removeNode
```
protected boolean removeNode(Node<java.lang.Object> o)
```
    指定者:
    
    removeNode 在类中 AbstractCTPQueue<E>
  - containsNode
```
protected boolean containsNode(Node<java.lang.Object> o)
```
    指定者:
    
    containsNode 在类中 AbstractCTPQueue<E>
  - containsAllNodes
```
protected boolean containsAllNodes(java.util.Collection<?> c)
```
    指定者:
    
    containsAllNodes 在类中 AbstractCTPQueue<E>
  - removeAllNodes
```
protected boolean removeAllNodes(java.util.Collection<?> c)
```
    指定者:
    
    removeAllNodes 在类中 AbstractCTPQueue<E>
  - retainAllNodes
```
protected boolean retainAllNodes(java.util.Collection<?> c)
```
    指定者:
    
    retainAllNodes 在类中 AbstractCTPQueue<E>

类 CTPBlockQueue<E>

字段概要

构造器概要

方法概要

从类继承的方法 com.seeyon.ctp.common.queue.AbstractCTPQueue

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

从接口继承的方法 java.util.Collection

从接口继承的方法 java.lang.Iterable

字段详细资料

queue

构造器详细资料

CTPBlockQueue

CTPBlockQueue

方法详细资料

size

isEmpty

clear

offer

offerNode

poll

take

put

pollNode

peekNode

getIterator

removeNode

containsNode

containsAllNodes

removeAllNodes

retainAllNodes