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
void	clearErrors()
java.lang.Object	deref()
java.lang.Object	dispatch(IFn fn, ISeq args, boolean solo)
ISeq	getErrors()
int	getQueueCount()
static int	releasePendingSends()
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 final java.util.concurrent.ExecutorService pooledExecutor

soloExecutor

public static final java.util.concurrent.ExecutorService soloExecutor

Constructor Detail

Agent

public Agent(java.lang.Object state)
      throws java.lang.Exception

Throws:

java.lang.Exception

Agent

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

Throws:

java.lang.Exception

Method Detail

shutdown

public static void shutdown()

deref

public java.lang.Object deref()
                       throws java.lang.Exception

Throws:

java.lang.Exception

getErrors

public ISeq getErrors()

clearErrors

public void clearErrors()

dispatch

public java.lang.Object dispatch(IFn fn,
                                 ISeq args,
                                 boolean solo)

getQueueCount

public int getQueueCount()

releasePendingSends

public static int releasePendingSends()