public class ExecutionQueueImpl extends java.lang.Object implements ExecutionQueue
ExecutionQueue
implementation.Modifier and Type | Class and Description |
---|---|
class |
ExecutionQueueImpl.ExecutionQueueInputStream |
Modifier and Type | Field and Description |
---|---|
static java.util.concurrent.ConcurrentHashMap<java.lang.String,java.io.ObjectStreamClass> |
_classDescriptors |
Constructor and Description |
---|
ExecutionQueueImpl(java.lang.ClassLoader classLoader) |
Modifier and Type | Method and Description |
---|---|
void |
add(CommChannel channel) |
void |
add(CommGroup group) |
CommChannel |
consumeExport(java.lang.String exportId) |
java.lang.String |
createExport(CommChannel channel) |
int |
cycle() |
Continuation |
dequeueReaction() |
void |
dumpState(java.io.PrintStream ps) |
void |
enqueueReaction(Continuation continuation)
Add a continuation to the broth.
|
void |
flush() |
java.io.Serializable |
getGlobalData() |
java.util.Map<java.lang.Object,java.util.LinkedList<IndexedObject>> |
getIndex() |
boolean |
hasReactions()
Are there any reactions that can be executed in the broth?
|
boolean |
isComplete() |
void |
read(java.io.InputStream iis) |
void |
setClassLoader(java.lang.ClassLoader classLoader) |
void |
setGlobalData(java.io.Serializable data) |
void |
setReplacementMap(ReplacementMap replacementMap) |
void |
write(java.io.OutputStream oos) |
public static java.util.concurrent.ConcurrentHashMap<java.lang.String,java.io.ObjectStreamClass> _classDescriptors
public void setClassLoader(java.lang.ClassLoader classLoader)
setClassLoader
in interface ExecutionQueue
public void setReplacementMap(ReplacementMap replacementMap)
setReplacementMap
in interface ExecutionQueue
public java.util.Map<java.lang.Object,java.util.LinkedList<IndexedObject>> getIndex()
public void add(CommChannel channel)
add
in interface ExecutionQueue
public void enqueueReaction(Continuation continuation)
ExecutionQueue
enqueueReaction
in interface ExecutionQueue
continuation
- the Continuation
to add to the brothpublic Continuation dequeueReaction()
dequeueReaction
in interface ExecutionQueue
public void add(CommGroup group)
add
in interface ExecutionQueue
public int cycle()
cycle
in interface ExecutionQueue
public java.lang.String createExport(CommChannel channel)
createExport
in interface ExecutionQueue
public CommChannel consumeExport(java.lang.String exportId)
consumeExport
in interface ExecutionQueue
public boolean hasReactions()
ExecutionQueue
hasReactions
in interface ExecutionQueue
true
if there are "enabled" reactionspublic void flush()
flush
in interface ExecutionQueue
public void read(java.io.InputStream iis) throws java.io.IOException, java.lang.ClassNotFoundException
java.io.IOException
java.lang.ClassNotFoundException
public void write(java.io.OutputStream oos) throws java.io.IOException
java.io.IOException
public boolean isComplete()
isComplete
in interface ExecutionQueue
public void dumpState(java.io.PrintStream ps)
dumpState
in interface ExecutionQueue
public void setGlobalData(java.io.Serializable data)
public java.io.Serializable getGlobalData()