Class Overview
Manages a set of SimulationExecutor
s and a queue of Simulations to be
run on them.
Simulations can be added to the queue with addSimulation(long)
and
these will be executed as soon as the executors will allow. Tasks are split
equally among the SimulationExecutor
s up to each one's resource limit
(as given my maxConcurrent()
.
The ExecutorManager
thread acts as a Consumer and will continue to
run until a simulation with ID 0 is passed to addSimulation(long)
.
Once this is detected it will wait for all executors to finish then shutdown
the thread.
Summary
[Expand]
Inherited Constants |
From class
java.lang.Thread
int |
MAX_PRIORITY |
|
int |
MIN_PRIORITY |
|
int |
NORM_PRIORITY |
|
|
Public Methods |
void
|
addSimulation(long simId)
Add a simulation to be run by an executor in the pool.
|
void
|
run()
|
[Expand]
Inherited Methods |
From class
java.lang.Thread
static
int
|
activeCount()
|
final
void
|
checkAccess()
|
Object
|
clone()
|
int
|
countStackFrames()
|
static
Thread
|
currentThread()
|
void
|
destroy()
|
static
void
|
dumpStack()
|
static
int
|
enumerate(Thread[] arg0)
|
static
Map<Thread, StackTraceElement[]>
|
getAllStackTraces()
|
ClassLoader
|
getContextClassLoader()
|
static
Thread.UncaughtExceptionHandler
|
getDefaultUncaughtExceptionHandler()
|
long
|
getId()
|
final
String
|
getName()
|
final
int
|
getPriority()
|
StackTraceElement[]
|
getStackTrace()
|
Thread.State
|
getState()
|
final
ThreadGroup
|
getThreadGroup()
|
Thread.UncaughtExceptionHandler
|
getUncaughtExceptionHandler()
|
static
boolean
|
holdsLock(Object arg0)
|
void
|
interrupt()
|
static
boolean
|
interrupted()
|
final
boolean
|
isAlive()
|
final
boolean
|
isDaemon()
|
boolean
|
isInterrupted()
|
final
void
|
join()
|
synchronized
final
void
|
join(long arg0)
|
synchronized
final
void
|
join(long arg0, int arg1)
|
final
void
|
resume()
|
void
|
run()
|
void
|
setContextClassLoader(ClassLoader arg0)
|
final
void
|
setDaemon(boolean arg0)
|
static
void
|
setDefaultUncaughtExceptionHandler(Thread.UncaughtExceptionHandler arg0)
|
final
void
|
setName(String arg0)
|
final
void
|
setPriority(int arg0)
|
void
|
setUncaughtExceptionHandler(Thread.UncaughtExceptionHandler arg0)
|
static
void
|
sleep(long arg0)
|
static
void
|
sleep(long arg0, int arg1)
|
synchronized
void
|
start()
|
final
void
|
stop()
|
synchronized
final
void
|
stop(Throwable arg0)
|
final
void
|
suspend()
|
String
|
toString()
|
static
void
|
yield()
|
|
From class
java.lang.Object
Object
|
clone()
|
boolean
|
equals(Object arg0)
|
void
|
finalize()
|
final
Class<?>
|
getClass()
|
int
|
hashCode()
|
final
void
|
notify()
|
final
void
|
notifyAll()
|
String
|
toString()
|
final
void
|
wait()
|
final
void
|
wait(long arg0)
|
final
void
|
wait(long arg0, int arg1)
|
|
From interface
java.lang.Runnable
|
Public Constructors
public
ExecutorManager
()
Public Methods
public
void
addSimulation
(long simId)
Add a simulation to be run by an executor in the pool.