public class Agent extends ARef
Modifier and Type | Field and Description |
---|---|
static java.util.concurrent.ExecutorService |
pooledExecutor |
static java.util.concurrent.ExecutorService |
soloExecutor |
Constructor and Description |
---|
Agent(java.lang.Object state) |
Agent(java.lang.Object state,
IPersistentMap meta) |
Modifier and Type | Method and Description |
---|---|
java.lang.Object |
deref() |
java.lang.Object |
dispatch(IFn fn,
ISeq args,
boolean solo) |
java.lang.Throwable |
getError() |
IFn |
getErrorHandler() |
Keyword |
getErrorMode() |
int |
getQueueCount() |
static int |
releasePendingSends() |
java.lang.Object |
restart(java.lang.Object newState,
boolean clearActions) |
void |
setErrorHandler(IFn f) |
void |
setErrorMode(Keyword k) |
static void |
shutdown() |
addWatch, getValidator, getWatches, notifyWatches, removeWatch, setValidator
alterMeta, meta, resetMeta
public static final java.util.concurrent.ExecutorService pooledExecutor
public static final java.util.concurrent.ExecutorService soloExecutor
public Agent(java.lang.Object state) throws java.lang.Exception
java.lang.Exception
public Agent(java.lang.Object state, IPersistentMap meta) throws java.lang.Exception
java.lang.Exception
public static void shutdown()
public java.lang.Object deref() throws java.lang.Exception
java.lang.Exception
public java.lang.Throwable getError()
public void setErrorMode(Keyword k)
public Keyword getErrorMode()
public void setErrorHandler(IFn f)
public IFn getErrorHandler()
public java.lang.Object restart(java.lang.Object newState, boolean clearActions)
public int getQueueCount()
public static int releasePendingSends()