org.objectweb.dream.pump
Class PumpSynchronizedImpl
java.lang.Object
org.objectweb.dream.AbstractComponent
org.objectweb.dream.pump.AbstractPumpSynchronizedImpl
org.objectweb.dream.pump.PumpSynchronizedImpl
- All Implemented Interfaces:
- ActiveComponentAttributeController, ContextualBindingController, NeedAsyncStartController, PrepareStopLifeCycleController, Loggable, PumpAttributeController, PumpAttributeControllerThreadPool, AttributeController, BindingController, LifeCycleController
public class PumpSynchronizedImpl
- extends AbstractPumpSynchronizedImpl
- implements PumpAttributeControllerThreadPool, ActiveComponentAttributeController
Synchronized implementation of a Pull/Push pump. This component has an
optional Mutex
client interface that it
uses to synchronize the execution of its run method with other components.
- See Also:
AbstractPumpSynchronizedImpl
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
usePool
protected boolean usePool
initialNumberOfThreads
protected int initialNumberOfThreads
PumpSynchronizedImpl
public PumpSynchronizedImpl()
setUsePool
public void setUsePool(boolean usePool)
- Specified by:
setUsePool
in interface ActiveComponentAttributeController
- See Also:
ActiveComponentAttributeController.setUsePool(boolean)
getUsePool
public boolean getUsePool()
- Specified by:
getUsePool
in interface ActiveComponentAttributeController
- See Also:
ActiveComponentAttributeController.getUsePool()
setInitialNumberOfThreads
public void setInitialNumberOfThreads(int i)
- Specified by:
setInitialNumberOfThreads
in interface ActiveComponentAttributeController
- See Also:
ActiveComponentAttributeController.setInitialNumberOfThreads(int)
getInitialNumberOfThreads
public int getInitialNumberOfThreads()
- Specified by:
getInitialNumberOfThreads
in interface ActiveComponentAttributeController
- See Also:
ActiveComponentAttributeController.getInitialNumberOfThreads()
startFc
public void startFc()
throws IllegalLifeCycleException
- Specified by:
startFc
in interface LifeCycleController
- Overrides:
startFc
in class AbstractComponent
- Throws:
IllegalLifeCycleException
- See Also:
LifeCycleController.startFc()
beforeFirstStart
protected void beforeFirstStart(Component componentItf)
throws IllegalLifeCycleException
- Overrides:
beforeFirstStart
in class AbstractComponent
- Throws:
IllegalLifeCycleException
- See Also:
AbstractComponent.beforeFirstStart(Component)
Copyright © 2003, 2005 - INRIA Rhone-Alpes - All Rights Reserved.