org.syrup.test
Class PureFunctionsRun

java.lang.Object
  extended byjava.lang.Thread
      extended byorg.syrup.test.PureFunctionsRun
All Implemented Interfaces:
java.lang.Runnable

public class PureFunctionsRun
extends java.lang.Thread

Takes a Workflow from stdin that should only contain pure Tasks and executes the Workflow by multiple Workers. The final state of the WorkSpace (when there are no more executable Tasks) is send to stdout. The number of Workers can be optionally specified by the first argument (defaults to 2).

Author:
Robbert van Dalen

Field Summary
 
Fields inherited from class java.lang.Thread
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
 
Constructor Summary
PureFunctionsRun()
           
 
Method Summary
 java.lang.Exception getException()
           
static void main(java.lang.String[] args)
           
static void operate(java.lang.String[] args, java.io.InputStream in, java.io.OutputStream out)
           
 void run()
           
 
Methods inherited from class java.lang.Thread
activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getContextClassLoader, getName, getPriority, getThreadGroup, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setName, setPriority, sleep, sleep, start, stop, stop, suspend, toString, yield
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

PureFunctionsRun

public PureFunctionsRun()
Method Detail

main

public static void main(java.lang.String[] args)
                 throws java.lang.Exception
Throws:
java.lang.Exception

operate

public static void operate(java.lang.String[] args,
                           java.io.InputStream in,
                           java.io.OutputStream out)
                    throws java.lang.Exception
Throws:
java.lang.Exception

run

public void run()

getException

public java.lang.Exception getException()