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

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) static class	Agent.Action
(package private) static class	Agent.ActionQueue

Field Summary

Fields

Modifier and Type	Field and Description
(package private) java.util.concurrent.atomic.AtomicReference<Agent.ActionQueue>	aq
(package private) static Keyword	CONTINUE
(package private) IFn	errorHandler
(package private) Keyword	errorMode
(package private) static Keyword	FAIL
(package private) static java.lang.ThreadLocal<IPersistentVector>	nested
static java.util.concurrent.ExecutorService	pooledExecutor
private static java.util.concurrent.atomic.AtomicLong	sendOffThreadPoolCounter
private static java.util.concurrent.atomic.AtomicLong	sendThreadPoolCounter
static java.util.concurrent.ExecutorService	soloExecutor
(package private) java.lang.Object	state

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

Methods

Modifier and Type	Method and Description
private static java.util.concurrent.ThreadFactory	createThreadFactory(java.lang.String format, java.util.concurrent.atomic.AtomicLong threadPoolCounter)
java.lang.Object	deref()
java.lang.Object	dispatch(IFn fn, ISeq args, java.util.concurrent.Executor exec)
(package private) static void	dispatchAction(Agent.Action action)
(package private) void	enqueue(Agent.Action action)
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)
(package private) boolean	setState(java.lang.Object newState)
static void	shutdown()

Methods inherited from class clojure.lang.ARef

addWatch, getValidator, getWatches, notifyWatches, removeWatch, setValidator, validate, validate

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

CONTINUE

static final Keyword CONTINUE

FAIL

static final Keyword FAIL

state

volatile java.lang.Object state

aq

java.util.concurrent.atomic.AtomicReference<Agent.ActionQueue> aq

errorMode

volatile Keyword errorMode

errorHandler

volatile IFn errorHandler

sendThreadPoolCounter

private static final java.util.concurrent.atomic.AtomicLong sendThreadPoolCounter

sendOffThreadPoolCounter

private static final java.util.concurrent.atomic.AtomicLong sendOffThreadPoolCounter

pooledExecutor

public static volatile java.util.concurrent.ExecutorService pooledExecutor

soloExecutor

public static volatile java.util.concurrent.ExecutorService soloExecutor

nested

static final java.lang.ThreadLocal<IPersistentVector> nested

Constructor Detail

Agent

public Agent(java.lang.Object state)

Agent

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

Method Detail

createThreadFactory

private static java.util.concurrent.ThreadFactory createThreadFactory(java.lang.String format,
                                                     java.util.concurrent.atomic.AtomicLong threadPoolCounter)

shutdown

public static void shutdown()

setState

boolean setState(java.lang.Object newState)

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)

dispatchAction

static void dispatchAction(Agent.Action action)

enqueue

void enqueue(Agent.Action action)

getQueueCount

public int getQueueCount()

releasePendingSends

public static int releasePendingSends()