tassl.application.node.isolate
Class IsolatedWorker

java.lang.Object
  java.lang.Thread
      tassl.application.node.isolate.IsolatedWorker

All Implemented Interfaces:

java.lang.Runnable, tassl.automate.application.node.isolate.TaskListenerInterface

public class IsolatedWorker
extends java.lang.Thread
implements tassl.automate.application.node.isolate.TaskListenerInterface

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

protected static boolean	ALIVE
static long	compute_time

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

IsolatedWorker()

IsolatedWorker(int port)

IsolatedWorker(int port, java.lang.String ip)

IsolatedWorker(int port, java.lang.String ip, java.lang.String worker_base_dir, java.lang.String partitionid)

Method Summary

void	consumeTask(tassl.automate.comet.XmlTuple task)
void	customizedProcess(java.lang.Object receivedObject)
java.lang.Object	customizedReadStream(java.io.DataInputStream in)
tassl.automate.programmodel.masterworker.WorkerFramework	getWorker()
void	loadWorker()
void	requestTask()
void	run()
void	setIWworkflow(boolean IWworkflow)

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

ALIVE

protected static boolean ALIVE

compute_time

public static long compute_time

Constructor Detail

IsolatedWorker

public IsolatedWorker()

IsolatedWorker

public IsolatedWorker(int port)

IsolatedWorker

public IsolatedWorker(int port,
                      java.lang.String ip)

IsolatedWorker

public IsolatedWorker(int port,
                      java.lang.String ip,
                      java.lang.String worker_base_dir,
                      java.lang.String partitionid)

Method Detail

setIWworkflow

public void setIWworkflow(boolean IWworkflow)

run

public void run()

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread

loadWorker

public void loadWorker()

getWorker

public tassl.automate.programmodel.masterworker.WorkerFramework getWorker()

requestTask

public void requestTask()

customizedReadStream

public java.lang.Object customizedReadStream(java.io.DataInputStream in)

Specified by:

customizedReadStream in interface tassl.automate.application.node.isolate.TaskListenerInterface

customizedProcess

public void customizedProcess(java.lang.Object receivedObject)

Specified by:

customizedProcess in interface tassl.automate.application.node.isolate.TaskListenerInterface

consumeTask

public void consumeTask(tassl.automate.comet.XmlTuple task)