fi.techila.user

Class TechilaExecutorService<T>

java.lang.Object

java.lang.Thread

fi.techila.user.TechilaExecutorService<T>

Type Parameters:

T -

All Implemented Interfaces:

java.lang.Runnable, java.util.concurrent.Executor, java.util.concurrent.ExecutorService

public class TechilaExecutorService<T>
extends java.lang.Thread
implements java.util.concurrent.ExecutorService

TechilaExecutorService. The start method must be called to actually start the execution of tasks in the Techila environment. Only submitting Callables (with submit(Callable)) is supported at this time. TechilaExecutorService is a single use service, it cannot be restarted / reused. If more than one project is needed, create a new TechilaExecutorService for each one.

Nested Class Summary

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

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

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
TechilaExecutorService()
TechilaExecutorService(java.lang.String description)
TechilaExecutorService(TechilaManager tm, java.lang.String description)

Method Summary

Modifier and Type	Method and Description
void	addClassFile(java.io.File file) Add a class file for the execution.
void	addClassFile(java.lang.String file) Add a class file for the execution.
void	addJarFile(java.io.File file) Add a JAR file for the execution.
void	addJarFile(java.lang.String file) Add a JAR file for the execution.
boolean	awaitTermination(long timeout, java.util.concurrent.TimeUnit unit)
void	execute(java.lang.Runnable runnable)
Peach	getPeach() Get the internal Peach class responsible for the execution of the tasks.
<T> java.util.List<java.util.concurrent.Future<T>>	invokeAll(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks)
<T> java.util.List<java.util.concurrent.Future<T>>	invokeAll(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks, long timeout, java.util.concurrent.TimeUnit unit)
<T> T	invokeAny(java.util.Collection<? extends java.util.concurrent.Callable<T>> task)
<T> T	invokeAny(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks, long timeout, java.util.concurrent.TimeUnit unit)
boolean	isShutdown()
boolean	isTerminated()
void	registerCallback(TechilaExecutorServiceCallback<T> callback) Register a callback class to be called when events happen.
void	registerQueue(java.util.concurrent.BlockingQueue queue)
void	run()
void	sendIMData(long jobid, java.lang.Object data) Send intermediate data to a job.
void	setLocal(int numberOfThreads) Enable local processing, Techila workers are not used.
void	setSteps(int steps) Set the number of steps to be run in each job.
void	setStream(boolean stream) Enable streaming for results.
void	setTechila() Set processing to be done on the Techila Workers.
void	shutdown()
java.util.List<java.lang.Runnable>	shutdownNow()
<T> TechilaFutureTask<T>	submit(java.util.concurrent.Callable<T> task)
java.util.concurrent.Future<?>	submit(java.lang.Runnable task)
<T> java.util.concurrent.Future<T>	submit(java.lang.Runnable task, T result)

Methods inherited from class java.lang.Thread

activeCount, checkAccess, 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, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

TechilaExecutorService

public TechilaExecutorService()

TechilaExecutorService

public TechilaExecutorService(java.lang.String description)

TechilaExecutorService

public TechilaExecutorService(TechilaManager tm,
                              java.lang.String description)

Method Detail

registerQueue

public void registerQueue(java.util.concurrent.BlockingQueue queue)

registerCallback

public void registerCallback(TechilaExecutorServiceCallback<T> callback)

Register a callback class to be called when events happen.

Parameters:

callback -

setLocal

public void setLocal(int numberOfThreads)

Enable local processing, Techila workers are not used.

Parameters:

numberOfThreads - number of threads to use locally.

setTechila

public void setTechila()

Set processing to be done on the Techila Workers. This is the default.

setStream

public void setStream(boolean stream)

Enable streaming for results. Most useful when using callbacks.

Parameters:

stream -

setSteps

public void setSteps(int steps)

Set the number of steps to be run in each job. Each job will run the specified number of tasks (the last job may run less). This is extremely useful when a single task is very short.

Parameters:

steps - number of steps / tasks

addClassFile

public void addClassFile(java.lang.String file)

Add a class file for the execution. Needed if the the class files are not automatically included in the project.

Parameters:

file -

addClassFile

public void addClassFile(java.io.File file)

Add a class file for the execution. Needed if the the class files are not automatically included in the project.

Parameters:

file -

addJarFile

public void addJarFile(java.lang.String file)

Add a JAR file for the execution. The file will be automatically included in the classpath on the workers.

Parameters:

file -

addJarFile

public void addJarFile(java.io.File file)

Add a JAR file for the execution. The file will be automatically included in the classpath on the workers.

Parameters:

file -

getPeach

public Peach getPeach()
               throws java.lang.Exception

Get the internal Peach class responsible for the execution of the tasks.

Returns:

Throws:

java.lang.Exception

execute

public void execute(java.lang.Runnable runnable)

Specified by:

execute in interface java.util.concurrent.Executor

awaitTermination

public boolean awaitTermination(long timeout,
                                java.util.concurrent.TimeUnit unit)
                         throws java.lang.InterruptedException

Specified by:

awaitTermination in interface java.util.concurrent.ExecutorService

Throws:

java.lang.InterruptedException

invokeAll

public <T> java.util.List<java.util.concurrent.Future<T>> invokeAll(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks)

Specified by:

invokeAll in interface java.util.concurrent.ExecutorService

invokeAll

public <T> java.util.List<java.util.concurrent.Future<T>> invokeAll(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks,
                                                                    long timeout,
                                                                    java.util.concurrent.TimeUnit unit)

Specified by:

invokeAll in interface java.util.concurrent.ExecutorService

invokeAny

public <T> T invokeAny(java.util.Collection<? extends java.util.concurrent.Callable<T>> task)

Specified by:

invokeAny in interface java.util.concurrent.ExecutorService

invokeAny

public <T> T invokeAny(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks,
                       long timeout,
                       java.util.concurrent.TimeUnit unit)

Specified by:

invokeAny in interface java.util.concurrent.ExecutorService

isShutdown

public boolean isShutdown()

Specified by:

isShutdown in interface java.util.concurrent.ExecutorService

isTerminated

public boolean isTerminated()

Specified by:

isTerminated in interface java.util.concurrent.ExecutorService

shutdown

public void shutdown()

Specified by:

shutdown in interface java.util.concurrent.ExecutorService

shutdownNow

public java.util.List<java.lang.Runnable> shutdownNow()

Specified by:

shutdownNow in interface java.util.concurrent.ExecutorService

submit

public <T> TechilaFutureTask<T> submit(java.util.concurrent.Callable<T> task)

Specified by:

submit in interface java.util.concurrent.ExecutorService

submit

public java.util.concurrent.Future<?> submit(java.lang.Runnable task)

Specified by:

submit in interface java.util.concurrent.ExecutorService

submit

public <T> java.util.concurrent.Future<T> submit(java.lang.Runnable task,
                                                 T result)

Specified by:

submit in interface java.util.concurrent.ExecutorService

run

public void run()

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread

sendIMData

public void sendIMData(long jobid,
                       java.lang.Object data)

Send intermediate data to a job.

Parameters:

jobid - the job id (long format)

data - the data to be sent