Field Summary

Fields 

Modifiers	Name	Description
private int	maxForks
private java.util.concurrent.Semaphore	semaphore
private Pool	threadPool

Inherited fields 

Fields inherited from class	Fields
class DataflowSelectorActor	passIndex
class DataflowProcessorActor	CANNOT_OBTAIN_THE_SEMAPHORE_TO_FORK_OPERATOR_S_BODY, code, inputs, outputs, owningProcessor, stoppingGently
class StaticDispatchActor	serialVersionUID
class AbstractLoopingActor	core, currentSender, currentTimerTask, serialVersionUID, stoppedFlag, terminatedFlag, terminatingFlag, timeoutCounter
class Actor	ACTOR_HAS_ALREADY_BEEN_STARTED, AFTER_START, CANNOT_SEND_REPLIES_NO_SENDER_HAS_BEEN_REGISTERED, EMPTY_ARGUMENTS, ON_DELIVERY_ERROR, RESPONDS_TO, START_MESSAGE, STOP_MESSAGE, TERMINATE_MESSAGE, TIMEOUT, TIMEOUT_MESSAGE, currentActorPerThread, currentThread, joinLatch, onStop, parallelGroup, serialVersionUID, timer
class MessageStream	serialVersionUID
class WithSerialId	serialHandle, serialVersionUID

Constructor Summary

Constructors 

Constructor and description
ForkingDataflowSelectorActor (DataflowSelector owningOperator, PGroup group, java.util.List outputs, java.util.List inputs, groovy.lang.Closure code, int maxForks)

Methods Summary

Methods 

Type	Name and description
protected void	forwardPoisonPill(java.lang.Object data)
void	startTask(int index, java.lang.Object result)

Inherited Methods Summary

Inherited Methods 

Methods inherited from class	Name
class DataflowSelectorActor	afterStart, handlePoisonPillInSelector, onMessage, startTask
class DataflowProcessorActor	afterStart, afterStop, checkPoison, fireMessageArrived, forwardPoisonPill, isControlMessage, onException, onMessage, registerChannelListenersToAllInputs, reportException, send
class StaticDispatchActor	onMessage
class AbstractLoopingActor	cancelCurrentTimeoutTask, doStart, getCore, getSender, hasBeenStopped, initialize, isActive, isFair, makeFair, reply, replyIfExists, runEnhancedWithoutRepliesOnMessages, send, setParallelGroup, setTimeout, silentStart, start, stop, sweepNextMessage, terminate
class Actor	callDynamic, createActorMessage, createRemoteHandle, deregisterCurrentActorWithThread, getJoinLatch, getParallelGroup, handleException, handleInterrupt, handleStart, handleTermination, handleTimeout, hasBeenStopped, isActive, isActorThread, join, join, join, join, onStop, registerCurrentActorWithThread, sendAndContinue, sendAndPromise, setParallelGroup, silentStart, start, stop, sweepNextMessage, sweepQueue, terminate, threadBoundActor
class MessageStream	call, getRemoteClass, leftShift, reInterrupt, send, send, send, sendAndWait, sendAndWait, sendAndWait
class WithSerialId	createRemoteHandle, getOrCreateSerialHandle, getRemoteClass, writeReplace
class java.lang.Object	java.lang.Object#wait(), java.lang.Object#wait(long, int), java.lang.Object#wait(long), java.lang.Object#equals(java.lang.Object), java.lang.Object#toString(), java.lang.Object#hashCode(), java.lang.Object#getClass(), java.lang.Object#notify(), java.lang.Object#notifyAll()