T - public class TechilaExecutorService<T>
extends java.lang.Thread
implements java.util.concurrent.ExecutorService
| Constructor and Description |
|---|
TechilaExecutorService() |
TechilaExecutorService(java.lang.String description) |
TechilaExecutorService(TechilaManager tm,
java.lang.String description) |
| 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) |
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, yieldpublic TechilaExecutorService()
public TechilaExecutorService(java.lang.String description)
public TechilaExecutorService(TechilaManager tm, java.lang.String description)
public void registerQueue(java.util.concurrent.BlockingQueue queue)
public void registerCallback(TechilaExecutorServiceCallback<T> callback)
callback - public void setLocal(int numberOfThreads)
numberOfThreads - number of threads to use locally.public void setTechila()
public void setStream(boolean stream)
stream - public void setSteps(int steps)
steps - number of steps / taskspublic void addClassFile(java.lang.String file)
file - public void addClassFile(java.io.File file)
file - public void addJarFile(java.lang.String file)
file - public void addJarFile(java.io.File file)
file - public Peach getPeach() throws java.lang.Exception
java.lang.Exceptionpublic void execute(java.lang.Runnable runnable)
execute in interface java.util.concurrent.Executorpublic boolean awaitTermination(long timeout,
java.util.concurrent.TimeUnit unit)
throws java.lang.InterruptedException
awaitTermination in interface java.util.concurrent.ExecutorServicejava.lang.InterruptedExceptionpublic <T> java.util.List<java.util.concurrent.Future<T>> invokeAll(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks)
invokeAll in interface java.util.concurrent.ExecutorServicepublic <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)
invokeAll in interface java.util.concurrent.ExecutorServicepublic <T> T invokeAny(java.util.Collection<? extends java.util.concurrent.Callable<T>> task)
invokeAny in interface java.util.concurrent.ExecutorServicepublic <T> T invokeAny(java.util.Collection<? extends java.util.concurrent.Callable<T>> tasks,
long timeout,
java.util.concurrent.TimeUnit unit)
invokeAny in interface java.util.concurrent.ExecutorServicepublic boolean isShutdown()
isShutdown in interface java.util.concurrent.ExecutorServicepublic boolean isTerminated()
isTerminated in interface java.util.concurrent.ExecutorServicepublic void shutdown()
shutdown in interface java.util.concurrent.ExecutorServicepublic java.util.List<java.lang.Runnable> shutdownNow()
shutdownNow in interface java.util.concurrent.ExecutorServicepublic <T> TechilaFutureTask<T> submit(java.util.concurrent.Callable<T> task)
submit in interface java.util.concurrent.ExecutorServicepublic java.util.concurrent.Future<?> submit(java.lang.Runnable task)
submit in interface java.util.concurrent.ExecutorServicepublic <T> java.util.concurrent.Future<T> submit(java.lang.Runnable task,
T result)
submit in interface java.util.concurrent.ExecutorServicepublic void run()
run in interface java.lang.Runnablerun in class java.lang.Threadpublic void sendIMData(long jobid,
java.lang.Object data)
jobid - the job id (long format)data - the data to be sent