org.lightwolf.tools
Class SimpleFlowManager

java.lang.Object
  org.lightwolf.FlowManager
      org.lightwolf.tools.SimpleFlowManager

All Implemented Interfaces:

Serializable

public class SimpleFlowManager
extends FlowManager
implements Serializable

See Also:

Serialized Form

Constructor Summary

SimpleFlowManager(String name)

Method Summary

protected void	doStreamedFork(Flow requester, int n)
protected void	fork(Flow requester, int n)
int	getActiveCount()
protected ScheduledFuture<?>	schedule(Callable<?> callable, long delay, TimeUnit unit)
protected Future<?>	submit(Flow flow, Object message)

Methods inherited from class org.lightwolf.FlowManager

clearThread, createBranch, getDefault, getNext, prepareFork, setDefault, setNext

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SimpleFlowManager

public SimpleFlowManager(String name)

Method Detail

getActiveCount

public int getActiveCount()

schedule

protected ScheduledFuture<?> schedule(Callable<?> callable,
                                      long delay,
                                      TimeUnit unit)

Specified by:

schedule in class FlowManager

fork

protected void fork(Flow requester,
                    int n)

Specified by:

fork in class FlowManager

doStreamedFork

protected void doStreamedFork(Flow requester,
                              int n)

Specified by:

doStreamedFork in class FlowManager

submit

protected Future<?> submit(Flow flow,
                           Object message)

Specified by:

submit in class FlowManager