public class DistributedQueue<T extends java.io.Serializable>
extends java.lang.Object
Constructor and Description |
---|
DistributedQueue(ZkClient zkClient,
java.lang.String root) |
Modifier and Type | Method and Description |
---|---|
boolean |
isEmpty() |
boolean |
offer(T element) |
T |
peek() |
T |
poll() |