Overview  Package   Class  Deprecated  Index  Help 
org.codehaus.gpars
FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD

groovyx.gpars
[Java] Class DataflowMessagingRunnable

java.lang.Object
  groovy.lang.GroovyObjectSupport
      groovy.lang.Closure
          groovyx.gpars.DataflowMessagingRunnable

@SuppressWarnings({"rawtypes", "RawUseOfParameterizedType"})
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.

Authors:
Vaclav Pech

Field Summary
private java.lang.Class[] defaultParamTypes

private int numberOfParameters

private static long serialVersionUID

 
Fields inherited from class groovy.lang.Closure
OWNER_FIRST, DELEGATE_FIRST, OWNER_ONLY, DELEGATE_ONLY, TO_SELF, DONE, SKIP, IDENTITY
 
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 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
groovy.lang.Closure#run(), groovy.lang.Closure#setProperty(java.lang.String, java.lang.Object), groovy.lang.Closure#getProperty(java.lang.String), groovy.lang.Closure#clone(), groovy.lang.Closure#getParameterTypes(), groovy.lang.Closure#setDelegate(java.lang.Object), groovy.lang.Closure#getOwner(), groovy.lang.Closure#leftShift(java.lang.Object), groovy.lang.Closure#leftShift(groovy.lang.Closure), groovy.lang.Closure#rightShift(groovy.lang.Closure), groovy.lang.Closure#call(java.lang.Object), groovy.lang.Closure#call([Ljava.lang.Object;), groovy.lang.Closure#call(), groovy.lang.Closure#setResolveStrategy(int), groovy.lang.Closure#getMaximumNumberOfParameters(), groovy.lang.Closure#getResolveStrategy(), groovy.lang.Closure#getThisObject(), groovy.lang.Closure#getDelegate(), groovy.lang.Closure#getDirective(), groovy.lang.Closure#setDirective(int), groovy.lang.Closure#isCase(java.lang.Object), groovy.lang.Closure#asWritable(), groovy.lang.Closure#curry([Ljava.lang.Object;), groovy.lang.Closure#curry(java.lang.Object), groovy.lang.Closure#rcurry(java.lang.Object), groovy.lang.Closure#rcurry([Ljava.lang.Object;), groovy.lang.Closure#ncurry(int, [Ljava.lang.Object;), groovy.lang.Closure#ncurry(int, java.lang.Object), groovy.lang.Closure#memoize(), groovy.lang.Closure#memoizeAtMost(int), groovy.lang.Closure#memoizeAtLeast(int), groovy.lang.Closure#memoizeBetween(int, int), groovy.lang.Closure#trampoline(), groovy.lang.Closure#trampoline([Ljava.lang.Object;), groovy.lang.Closure#dehydrate(), groovy.lang.Closure#rehydrate(java.lang.Object, java.lang.Object, java.lang.Object), groovy.lang.Closure#getMetaClass(), groovy.lang.Closure#setMetaClass(groovy.lang.MetaClass), groovy.lang.Closure#invokeMethod(java.lang.String, java.lang.Object), groovy.lang.Closure#wait(long), groovy.lang.Closure#wait(), groovy.lang.Closure#wait(long, int), groovy.lang.Closure#equals(java.lang.Object), groovy.lang.Closure#toString(), groovy.lang.Closure#hashCode(), groovy.lang.Closure#getClass(), groovy.lang.Closure#notify(), groovy.lang.Closure#notifyAll()
 
Methods inherited from class groovy.lang.GroovyObjectSupport
groovy.lang.GroovyObjectSupport#setProperty(java.lang.String, java.lang.Object), groovy.lang.GroovyObjectSupport#getProperty(java.lang.String), groovy.lang.GroovyObjectSupport#getMetaClass(), groovy.lang.GroovyObjectSupport#setMetaClass(groovy.lang.MetaClass), groovy.lang.GroovyObjectSupport#invokeMethod(java.lang.String, java.lang.Object), groovy.lang.GroovyObjectSupport#wait(long), groovy.lang.GroovyObjectSupport#wait(), groovy.lang.GroovyObjectSupport#wait(long, int), groovy.lang.GroovyObjectSupport#equals(java.lang.Object), groovy.lang.GroovyObjectSupport#toString(), groovy.lang.GroovyObjectSupport#hashCode(), groovy.lang.GroovyObjectSupport#getClass(), groovy.lang.GroovyObjectSupport#notify(), groovy.lang.GroovyObjectSupport#notifyAll()
 

Field Detail

defaultParamTypes

private final java.lang.Class[] defaultParamTypes

numberOfParameters

private final int numberOfParameters

serialVersionUID

private static final long serialVersionUID

 
Constructor Detail

DataflowMessagingRunnable

protected DataflowMessagingRunnable(int numberOfParameters)

DataflowMessagingRunnable

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

 
Method Detail

call

@Override
public final java.lang.Object call()

call

@Override
public final java.lang.Object call(java.lang.Object... args)

doRun

protected void doRun(java.lang.Object... arguments)
Defines the action performed by the Runnable
Parameters:
arguments - The parameters passed from the caller to the closure

getMaximumNumberOfParameters

@Override
public int getMaximumNumberOfParameters()

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

getParameterTypes

@Override
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.
Returns:
Types of expected arguments

 

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