groovyx.gpars
Class DataflowMessagingRunnable

java.lang.Object
  extended by groovy.lang.GroovyObjectSupport
      extended by groovy.lang.Closure
          extended by groovyx.gpars.DataflowMessagingRunnable
All Implemented Interfaces:
groovy.lang.GroovyCallable, groovy.lang.GroovyObject, java.io.Serializable, java.lang.Cloneable, java.lang.Runnable, java.util.concurrent.Callable

public abstract class DataflowMessagingRunnable
extends groovy.lang.Closure

Represents a multi-argument Closure when using GPars dataflow operators and selectors through the Java API. The doRun() method is meant to be defined by implementers to specify the closure body.

Author:
Vaclav Pech
See Also:
Serialized Form

Field Summary
private  java.lang.Class[] defaultParamTypes
           
private  int numberOfParameters
           
private static long serialVersionUID
           
 
Fields inherited from class groovy.lang.Closure
DELEGATE_FIRST, DELEGATE_ONLY, DONE, IDENTITY, maximumNumberOfParameters, OWNER_FIRST, OWNER_ONLY, parameterTypes, SKIP, TO_SELF
 
Constructor Summary
protected DataflowMessagingRunnable(int numberOfParameters)
           
protected DataflowMessagingRunnable(java.lang.Object owner, int numberOfParameters)
           
 
Method Summary
 java.lang.Object call()
           
 java.lang.Object call(java.lang.Object... args)
           
protected abstract  void doRun(java.lang.Object... arguments)
          Defines the action performed by the Runnable
 int getMaximumNumberOfParameters()
           
 DataflowProcessor getOwningProcessor()
          Retrieves the owning processor (operator or selector) giving the DataflowMessagingRunnable a way to call methods like bindOutput()
 java.lang.Class[] getParameterTypes()
          Returns types expected by the Runnable.
 
Methods inherited from class groovy.lang.Closure
asWritable, call, clone, curry, curry, dehydrate, getDelegate, getDirective, getOwner, getProperty, getResolveStrategy, getThisObject, isCase, leftShift, leftShift, memoize, memoizeAtLeast, memoizeAtMost, memoizeBetween, ncurry, ncurry, rcurry, rcurry, rehydrate, rightShift, run, setDelegate, setDirective, setProperty, setResolveStrategy, throwRuntimeException, trampoline, trampoline
 
Methods inherited from class groovy.lang.GroovyObjectSupport
getMetaClass, invokeMethod, setMetaClass
 
Methods inherited from class java.lang.Object
equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

serialVersionUID

private static final long serialVersionUID
See Also:
Constant Field Values

defaultParamTypes

private final java.lang.Class[] defaultParamTypes

numberOfParameters

private final int numberOfParameters
Constructor Detail

DataflowMessagingRunnable

protected DataflowMessagingRunnable(int numberOfParameters)

DataflowMessagingRunnable

protected DataflowMessagingRunnable(java.lang.Object owner,
                                    int numberOfParameters)
Method Detail

getOwningProcessor

public DataflowProcessor getOwningProcessor()
Retrieves the owning processor (operator or selector) giving the DataflowMessagingRunnable a way to call methods like bindOutput()

Returns:
The owning processor

getMaximumNumberOfParameters

public int getMaximumNumberOfParameters()
Overrides:
getMaximumNumberOfParameters in class groovy.lang.Closure

getParameterTypes

public java.lang.Class[] getParameterTypes()
Returns types expected by the Runnable. By default instances of the Object class are demanded. The size of the array must match the numberOfParameters parameter to the constructor.

Overrides:
getParameterTypes in class groovy.lang.Closure
Returns:
Types of expected arguments

call

public final java.lang.Object call()
Specified by:
call in interface java.util.concurrent.Callable
Overrides:
call in class groovy.lang.Closure

call

public final java.lang.Object call(java.lang.Object... args)
Overrides:
call in class groovy.lang.Closure

doRun

protected abstract void doRun(java.lang.Object... arguments)
Defines the action performed by the Runnable

Parameters:
arguments - The parameters passed from the caller to the closure

Copyright © 2008–2012 Václav Pech. All Rights Reserved.