clojure.lang

Class Agent

java.lang.Object

clojure.lang.AReference

clojure.lang.ARef

clojure.lang.Agent

All Implemented Interfaces:

IDeref, IMeta, IRef, IReference

public class Agent
extends ARef

Field Summary

Fields

Modifier and Type	Field and Description
static java.util.concurrent.ExecutorService	pooledExecutor
static java.util.concurrent.ExecutorService	soloExecutor

Fields inherited from class clojure.lang.ARef

validator

Constructor Summary

Constructors

Constructor and Description
Agent(java.lang.Object state)
Agent(java.lang.Object state, IPersistentMap meta)

Method Summary

Modifier and Type	Method and Description
java.lang.Object	deref()
java.lang.Object	dispatch(IFn fn, ISeq args, java.util.concurrent.Executor exec)
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()

Methods inherited from class clojure.lang.ARef

addWatch, getValidator, getWatches, notifyWatches, removeWatch, setValidator

Methods inherited from class clojure.lang.AReference

alterMeta, meta, resetMeta

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

pooledExecutor

public static volatile java.util.concurrent.ExecutorService pooledExecutor

soloExecutor

public static volatile java.util.concurrent.ExecutorService soloExecutor

Constructor Detail

Agent

public Agent(java.lang.Object state)

Agent

public Agent(java.lang.Object state,
             IPersistentMap meta)

Method Detail

shutdown

public static void shutdown()

deref

public java.lang.Object deref()

getError

public java.lang.Throwable getError()

setErrorMode

public void setErrorMode(Keyword k)

getErrorMode

public Keyword getErrorMode()

setErrorHandler

public void setErrorHandler(IFn f)

getErrorHandler

public IFn getErrorHandler()

restart

public java.lang.Object restart(java.lang.Object newState,
                                boolean clearActions)

dispatch

public java.lang.Object dispatch(IFn fn,
                                 ISeq args,
                                 java.util.concurrent.Executor exec)

getQueueCount

public int getQueueCount()

releasePendingSends

public static int releasePendingSends()