|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object | +--org.objectweb.proactive.core.event.AbstractEventProducer | +--org.objectweb.proactive.core.body.request.RequestQueueImpl
Nested Class Summary |
Nested classes inherited from class org.objectweb.proactive.core.event.AbstractEventProducer |
AbstractEventProducer.ListenerList |
Field Summary | |
protected UniqueID |
ownerID
|
protected CircularArrayList |
requestQueue
|
protected static boolean |
SEND_ADD_REMOVE_EVENT
|
Fields inherited from class org.objectweb.proactive.core.event.AbstractEventProducer |
eventListeners, logger, shouldSerializeListeners |
Constructor Summary | |
RequestQueueImpl(UniqueID ownerID)
|
Method Summary | |
void |
add(Request request)
Adds the given request to the end of the queue |
void |
addRequestQueueEventListener(RequestQueueEventListener listener)
|
void |
addToFront(Request request)
Adds the given request to the front of the queue before all other request already in the queue |
void |
clear()
|
Request |
getOldest()
Returns the oldest request from the queue or null if the queue is empty Do not remove it from the queue |
Request |
getOldest(RequestFilter requestFilter)
Returns the oldest request that matches the criteria defined by the given filter Do not remove it from the request line |
Request |
getOldest(java.lang.String methodName)
Returns the oldest request whose method name is s or null if no match Do not remove it from the queue |
Request |
getYoungest()
Returns the youngest request from the queue or null if the queue is empty Do not remove it from the request line |
Request |
getYoungest(RequestFilter requestFilter)
Returns the youngest request that matches the criteria defined by the given filter Do not remove it from the request line |
Request |
getYoungest(java.lang.String methodName)
Returns the youngest request whose method name is s or null if no match Do not remove it from the request line |
boolean |
hasRequest(java.lang.String s)
|
boolean |
isEmpty()
|
java.util.Iterator |
iterator()
Returns an iterator over all the requests in the request queue. |
protected void |
notifyOneListener(ProActiveListener listener,
ProActiveEvent event)
Notifies one listener with the event. |
void |
processRequests(RequestProcessor processor,
Body body)
Processes all requests in the queue using the given RequestProcessor. |
Request |
removeOldest()
Removes the oldest request from the queue and returns it Null is returned is the queue is empty |
Request |
removeOldest(RequestFilter requestFilter)
Removes the oldest request that matches the criteria defined by the given filter Null is returned is no match |
Request |
removeOldest(java.lang.String methodName)
Removes the oldest request whose method name is s and returns it. |
void |
removeRequestQueueEventListener(RequestQueueEventListener listener)
|
Request |
removeYoungest()
Removes the youngest request from the queue and returns it Null is returned is the queue is empty |
Request |
removeYoungest(RequestFilter requestFilter)
Removes the youngest request that matches the criteria defined by the given filter Null is returned is no match |
Request |
removeYoungest(java.lang.String methodName)
Removes the youngest request whose method name is s and returns it. |
int |
size()
|
java.lang.String |
toString()
|
Methods inherited from class org.objectweb.proactive.core.event.AbstractEventProducer |
addListener, hasListeners, notifyAllListeners, removeListener |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Field Detail |
protected CircularArrayList requestQueue
protected UniqueID ownerID
protected static final boolean SEND_ADD_REMOVE_EVENT
Constructor Detail |
public RequestQueueImpl(UniqueID ownerID)
Method Detail |
public java.util.Iterator iterator()
RequestQueue
iterator
in interface RequestQueue
public boolean isEmpty()
isEmpty
in interface RequestQueue
public int size()
size
in interface RequestQueue
public boolean hasRequest(java.lang.String s)
hasRequest
in interface RequestQueue
public void clear()
clear
in interface RequestQueue
public Request getOldest()
RequestQueue
getOldest
in interface RequestQueue
public Request getOldest(java.lang.String methodName)
RequestQueue
getOldest
in interface RequestQueue
methodName
- the name of the method to look for
public Request getOldest(RequestFilter requestFilter)
RequestQueue
getOldest
in interface RequestQueue
requestFilter
- the filter accepting request on a given criteria
public Request removeOldest()
RequestQueue
removeOldest
in interface RequestQueue
public Request removeOldest(java.lang.String methodName)
RequestQueue
removeOldest
in interface RequestQueue
methodName
- the name of the method to look for
public Request removeOldest(RequestFilter requestFilter)
RequestQueue
removeOldest
in interface RequestQueue
requestFilter
- the filter accepting request on a given criteria
public Request getYoungest()
RequestQueue
getYoungest
in interface RequestQueue
public Request getYoungest(java.lang.String methodName)
RequestQueue
getYoungest
in interface RequestQueue
methodName
- the name of the method to look for
public Request getYoungest(RequestFilter requestFilter)
RequestQueue
getYoungest
in interface RequestQueue
requestFilter
- the filter accepting request on a given criteria
public Request removeYoungest()
RequestQueue
removeYoungest
in interface RequestQueue
public Request removeYoungest(java.lang.String methodName)
RequestQueue
removeYoungest
in interface RequestQueue
methodName
- the name of the method to look for
public Request removeYoungest(RequestFilter requestFilter)
RequestQueue
removeYoungest
in interface RequestQueue
requestFilter
- the filter accepting request on a given criteria
public void add(Request request)
RequestQueue
add
in interface RequestQueue
request
- the request to addpublic void addToFront(Request request)
RequestQueue
addToFront
in interface RequestQueue
request
- the request to addpublic void processRequests(RequestProcessor processor, Body body)
RequestQueue
processRequests
in interface RequestQueue
processor
- the RequestProcessor to usebody
- the body that processes the requestspublic java.lang.String toString()
toString
in class java.lang.Object
public void addRequestQueueEventListener(RequestQueueEventListener listener)
addRequestQueueEventListener
in interface RequestQueue
public void removeRequestQueueEventListener(RequestQueueEventListener listener)
removeRequestQueueEventListener
in interface RequestQueue
protected void notifyOneListener(ProActiveListener listener, ProActiveEvent event)
AbstractEventProducer
notifyOneListener
in class AbstractEventProducer
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |