gpars.dataflow.operator
Class ForkingDataFlowOperatorActor
java.lang.Object
groovyx.gpars.actor.AbstractPooledActor
gpars.dataflow.operator.DataFlowOperatorActor
gpars.dataflow.operator.ForkingDataFlowOperatorActor
class ForkingDataFlowOperatorActor
extends DataFlowOperatorActor
An operator's internal actor. Repeatedly polls inputs and once they're all available it performs the operator's body.
The operator's body is executed in as a separate task, allowing multiple copies of the body to be run concurrently.
The maxForks property guards the maximum number or concurrently run copies.
semaphore
final Semaphore semaphore
-
ForkingDataFlowOperatorActor
public ForkingDataFlowOperatorActor(def owningOperator, def outputs, def inputs, def code, def maxForks)
-
startTask
public def startTask(def results)
-
Groovy Documentation