|
|||||||||
| Home >> All >> org >> activemq >> [ ra overview ] | PREV CLASS NEXT CLASS | ||||||||
SUMMARY: JAVADOC | SOURCE | DOWNLOAD | NESTED | FIELD | CONSTR | METHOD |
DETAIL: FIELD | CONSTR | METHOD | ||||||||
org.activemq.ra
Class CircularQueue

java.lang.Objectorg.activemq.ra.CircularQueue
- public class CircularQueue
- extends java.lang.Object
| Field Summary | |
private java.lang.Object[] |
contents
|
private int |
end
|
private java.lang.Object |
mutex
|
private int |
size
|
private int |
start
|
private SynchronizedBoolean |
stopping
|
| Constructor Summary | |
CircularQueue(int size,
SynchronizedBoolean stopping)
|
|
| Method Summary | |
void |
drain()
|
java.lang.Object |
get()
|
void |
notifyWaiting()
|
void |
returnObject(java.lang.Object worker)
|
int |
size()
|
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Field Detail |
size
private final int size
stopping
private final SynchronizedBoolean stopping
contents
private final java.lang.Object[] contents
mutex
private final java.lang.Object mutex
start
private int start
end
private int end
| Constructor Detail |
CircularQueue
public CircularQueue(int size,
SynchronizedBoolean stopping)
| Method Detail |
get
public java.lang.Object get()
returnObject
public void returnObject(java.lang.Object worker)
size
public int size()
drain
public void drain()
notifyWaiting
public void notifyWaiting()
|
|||||||||
| Home >> All >> org >> activemq >> [ ra overview ] | PREV CLASS NEXT CLASS | ||||||||
SUMMARY: JAVADOC | SOURCE | DOWNLOAD | NESTED | FIELD | CONSTR | METHOD |
DETAIL: FIELD | CONSTR | METHOD | ||||||||
JAVADOC
org.activemq.ra.CircularQueue