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

@java.lang.SuppressWarnings}
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)

int getMaximumNumberOfParameters()

DataflowProcessor getOwningProcessor()

Returns types expected by the Runnable.

java.lang.Class[] getParameterTypes()

 
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#call([Ljava.lang.Object;), groovy.lang.Closure#call(java.lang.Object), groovy.lang.Closure#call(), groovy.lang.Closure#leftShift(groovy.lang.Closure), groovy.lang.Closure#leftShift(java.lang.Object), groovy.lang.Closure#rightShift(groovy.lang.Closure), groovy.lang.Closure#setResolveStrategy(int), groovy.lang.Closure#getMaximumNumberOfParameters(), groovy.lang.Closure#getResolveStrategy(), groovy.lang.Closure#getThisObject(), groovy.lang.Closure#memoizeAtMost(int), groovy.lang.Closure#memoizeAtLeast(int), groovy.lang.Closure#memoizeBetween(int, int), 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#trampoline([Ljava.lang.Object;), groovy.lang.Closure#trampoline(), groovy.lang.Closure#dehydrate(), groovy.lang.Closure#rehydrate(java.lang.Object, java.lang.Object, java.lang.Object), groovy.lang.Closure#invokeMethod(java.lang.String, java.lang.Object), groovy.lang.Closure#getMetaClass(), groovy.lang.Closure#setMetaClass(groovy.lang.MetaClass), groovy.lang.Closure#wait(long, int), groovy.lang.Closure#wait(long), groovy.lang.Closure#wait(), 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#invokeMethod(java.lang.String, java.lang.Object), groovy.lang.GroovyObjectSupport#getMetaClass(), groovy.lang.GroovyObjectSupport#setMetaClass(groovy.lang.MetaClass), groovy.lang.GroovyObjectSupport#wait(long, int), groovy.lang.GroovyObjectSupport#wait(long), groovy.lang.GroovyObjectSupport#wait(), 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

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

call

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

doRun

protected void doRun(java.lang.Object... arguments)

getMaximumNumberOfParameters

@java.lang.Override
public int getMaximumNumberOfParameters()

getOwningProcessor

public DataflowProcessor getOwningProcessor()
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

getParameterTypes

@java.lang.Override
public java.lang.Class[] getParameterTypes()

 

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