Groovy Documentation

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.


Property Summary
Semaphore semaphore

 
Constructor Summary
ForkingDataFlowOperatorActor(def owningOperator, def outputs, def inputs, def code, def maxForks)

 
Method Summary
def startTask(def results)

 
Methods inherited from class DataFlowOperatorActor
act, handleValueMessage, reportException, startTask
 

Property Detail

semaphore

final Semaphore semaphore


 
Constructor Detail

ForkingDataFlowOperatorActor

public ForkingDataFlowOperatorActor(def owningOperator, def outputs, def inputs, def code, def maxForks)


 
Method Detail

startTask

public def startTask(def results)


 

Groovy Documentation