org.objectweb.dream.pump
Class PumpSynchronizedImpl

java.lang.Object
  extended by org.objectweb.dream.AbstractComponent
      extended by org.objectweb.dream.pump.AbstractPumpSynchronizedImpl
          extended by 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 Mutexclient interface that it uses to synchronize the execution of its run method with other components.

See Also:
AbstractPumpSynchronizedImpl

Field Summary
protected  int initialNumberOfThreads
           
protected  boolean usePool
           
 
Fields inherited from class org.objectweb.dream.pump.AbstractPumpSynchronizedImpl
inPullItf, messageManagerItf, mutexItf, outPushItf, pumpTask, pushNullPolicy, stopOnPullExceptionPolicy, stopOnPushExceptionPolicy
 
Fields inherited from class org.objectweb.dream.AbstractComponent
bindingLogger, fcNeedAsyncStart, fcState, lifeCycleLogger, logger, weaveableC
 
Fields inherited from interface org.objectweb.fractal.api.control.LifeCycleController
STARTED, STOPPED
 
Constructor Summary
PumpSynchronizedImpl()
           
 
Method Summary
protected  void beforeFirstStart(Component componentItf)
           
 int getInitialNumberOfThreads()
           
 boolean getUsePool()
           
 void setInitialNumberOfThreads(int i)
           
 void setUsePool(boolean usePool)
           
 void startFc()
           
 
Methods inherited from class org.objectweb.dream.pump.AbstractPumpSynchronizedImpl
bindFc, getPushNullPolicy, getStopOnPullExceptionPolicy, getStopOnPushExceptionPolicy, handlePullException, handlePushException, listFc, setPushNullPolicy, setStopOnPullExceptionPolicy, setStopOnPushExceptionPolicy
 
Methods inherited from class org.objectweb.dream.AbstractComponent
bindFc, getFcNeedAsyncStart, getFcState, initComponent, lookupFc, prepareStopFc, setLogger, stopFc, unbindFc
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface org.objectweb.dream.pump.PumpAttributeController
getPushNullPolicy, getStopOnPullExceptionPolicy, getStopOnPushExceptionPolicy, setPushNullPolicy, setStopOnPullExceptionPolicy, setStopOnPushExceptionPolicy
 

Field Detail

usePool

protected boolean usePool

initialNumberOfThreads

protected int initialNumberOfThreads
Constructor Detail

PumpSynchronizedImpl

public PumpSynchronizedImpl()
Method Detail

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.