net.wicp.tams.commons.zookeeper

类 DistributedQueue

java.lang.Object

net.wicp.tams.commons.zookeeper.DistributedQueue

public class DistributedQueue
extends Object

分布式队列，来自zk源码，做些修改

构造器概要

构造器

构造器和说明
DistributedQueue(String dir)

方法概要

方法

限定符和类型	方法和说明
byte[]	element() Return the head of the queue without modifying the queue.
boolean	offer(byte[] data) Inserts data into queue.
byte[]	peek() Returns the data at the first element of the queue, or null if the queue is empty.
byte[]	poll() Attempts to remove the head of the queue and return it.
byte[]	remove() Attempts to remove the head of the queue and return it.
byte[]	take() Removes the head of the queue and returns it, blocks until it succeeds.

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

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

构造器详细资料

DistributedQueue

public DistributedQueue(String dir)

方法详细资料

element

public byte[] element()
               throws NoSuchElementException,
                      org.apache.zookeeper.KeeperException,
                      InterruptedException

Return the head of the queue without modifying the queue.

返回:

the data at the head of the queue.

抛出:

NoSuchElementException

org.apache.zookeeper.KeeperException

InterruptedException

remove

public byte[] remove()
              throws NoSuchElementException,
                     org.apache.zookeeper.KeeperException,
                     InterruptedException

Attempts to remove the head of the queue and return it.

返回:

The former head of the queue

抛出:

NoSuchElementException

org.apache.zookeeper.KeeperException

InterruptedException

take

public byte[] take()
            throws org.apache.zookeeper.KeeperException,
                   InterruptedException

Removes the head of the queue and returns it, blocks until it succeeds.

返回:

The former head of the queue

抛出:

NoSuchElementException

org.apache.zookeeper.KeeperException

InterruptedException

offer

public boolean offer(byte[] data)
              throws org.apache.zookeeper.KeeperException,
                     InterruptedException

Inserts data into queue.

参数:

data -

返回:

true if data was successfully added

抛出:

org.apache.zookeeper.KeeperException

InterruptedException

peek

public byte[] peek()
            throws org.apache.zookeeper.KeeperException,
                   InterruptedException

Returns the data at the first element of the queue, or null if the queue is empty.

返回:

data at the first element of the queue, or null.

抛出:

org.apache.zookeeper.KeeperException

InterruptedException

poll

public byte[] poll()
            throws org.apache.zookeeper.KeeperException,
                   InterruptedException

Attempts to remove the head of the queue and return it. Returns null if the queue is empty.

返回:

Head of the queue or null.

抛出:

org.apache.zookeeper.KeeperException

InterruptedException