|
|||||||||||
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 | +--org.objectweb.proactive.core.body.request.BlockingRequestQueueImpl | +--org.objectweb.proactive.core.component.request.ComponentRequestQueueImpl
Extension of the standard ProActive request queue. It enables the control of the life cycle of components. The algorithm is the following : loop if componentLifeCycle.isStarted() get next request // all requests are served else if componentLifeCycle.isStopped() get next component controller request // only component request are served ; if gotten request is a component life cycle request if startFc --> set started = true if stopFc --> set started = false
Nested Class Summary |
Nested classes inherited from class org.objectweb.proactive.core.event.AbstractEventProducer |
AbstractEventProducer.ListenerList |
Field Summary | |
protected static org.apache.log4j.Logger |
logger
|
Fields inherited from class org.objectweb.proactive.core.body.request.BlockingRequestQueueImpl |
shouldWait |
Fields inherited from class org.objectweb.proactive.core.body.request.RequestQueueImpl |
ownerID, requestQueue, SEND_ADD_REMOVE_EVENT |
Fields inherited from class org.objectweb.proactive.core.event.AbstractEventProducer |
eventListeners, shouldSerializeListeners |
Constructor Summary | |
ComponentRequestQueueImpl(UniqueID ownerID)
Constructor for ComponentRequestQueueImpl. |
Method Summary | |
Request |
blockingRemoveOldest()
Blocks the calling thread until there is a request available Returns immediately if there is already one. |
boolean |
isStarted()
|
void |
start()
|
void |
stop()
|
Methods inherited from class org.objectweb.proactive.core.body.request.BlockingRequestQueueImpl |
add, addToFront, blockingRemove, blockingRemove, blockingRemove, blockingRemove, blockingRemoveOldest, blockingRemoveOldest, blockingRemoveOldest, blockingRemoveYoungest, blockingRemoveYoungest, blockingRemoveYoungest, blockingRemoveYoungest, destroy, isDestroyed, waitForRequest |
Methods inherited from class org.objectweb.proactive.core.body.request.RequestQueueImpl |
addRequestQueueEventListener, clear, getOldest, getOldest, getOldest, getYoungest, getYoungest, getYoungest, hasRequest, isEmpty, iterator, notifyOneListener, processRequests, removeOldest, removeOldest, removeOldest, removeRequestQueueEventListener, removeYoungest, removeYoungest, removeYoungest, size, 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 |
Methods inherited from interface org.objectweb.proactive.core.body.request.BlockingRequestQueue |
blockingRemoveOldest, blockingRemoveOldest, blockingRemoveOldest, blockingRemoveYoungest, blockingRemoveYoungest, blockingRemoveYoungest, blockingRemoveYoungest, destroy, isDestroyed, waitForRequest |
Methods inherited from interface org.objectweb.proactive.core.body.request.RequestQueue |
add, addRequestQueueEventListener, addToFront, clear, getOldest, getOldest, getOldest, getYoungest, getYoungest, getYoungest, hasRequest, isEmpty, iterator, processRequests, removeOldest, removeOldest, removeOldest, removeRequestQueueEventListener, removeYoungest, removeYoungest, removeYoungest, size |
Field Detail |
protected static org.apache.log4j.Logger logger
Constructor Detail |
public ComponentRequestQueueImpl(UniqueID ownerID)
ownerID
- Method Detail |
public void start()
start
in interface ComponentRequestQueue
public void stop()
stop
in interface ComponentRequestQueue
public boolean isStarted()
isStarted
in interface ComponentRequestQueue
public Request blockingRemoveOldest()
BlockingRequestQueue
blockingRemoveOldest
in interface BlockingRequestQueue
blockingRemoveOldest
in class BlockingRequestQueueImpl
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |