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 ExecutionQueuepublic void setReplacementMap(ReplacementMap replacementMap)
setReplacementMap in interface ExecutionQueuepublic java.util.Map<java.lang.Object,java.util.LinkedList<IndexedObject>> getIndex()
public void add(CommChannel channel)
add in interface ExecutionQueuepublic void enqueueReaction(Continuation continuation)
ExecutionQueueenqueueReaction in interface ExecutionQueuecontinuation - the Continuation to add to the brothpublic Continuation dequeueReaction()
dequeueReaction in interface ExecutionQueuepublic void add(CommGroup group)
add in interface ExecutionQueuepublic int cycle()
cycle in interface ExecutionQueuepublic java.lang.String createExport(CommChannel channel)
createExport in interface ExecutionQueuepublic CommChannel consumeExport(java.lang.String exportId)
consumeExport in interface ExecutionQueuepublic boolean hasReactions()
ExecutionQueuehasReactions in interface ExecutionQueuetrue if there are "enabled" reactionspublic void flush()
flush in interface ExecutionQueuepublic void read(java.io.InputStream iis)
throws java.io.IOException,
java.lang.ClassNotFoundException
java.io.IOExceptionjava.lang.ClassNotFoundExceptionpublic void write(java.io.OutputStream oos)
throws java.io.IOException
java.io.IOExceptionpublic boolean isComplete()
isComplete in interface ExecutionQueuepublic void dumpState(java.io.PrintStream ps)
dumpState in interface ExecutionQueuepublic void setGlobalData(java.io.Serializable data)
public java.io.Serializable getGlobalData()