clojure.lang

Class LockingTransaction

java.lang.Object

clojure.lang.LockingTransaction

public class LockingTransaction
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) static class	LockingTransaction.AbortException
(package private) static class	LockingTransaction.CFn
static class	LockingTransaction.Info
(package private) static class	LockingTransaction.Notify
(package private) static class	LockingTransaction.RetryEx

Field Summary

Fields

Modifier and Type	Field and Description
(package private) java.util.ArrayList<Agent.Action>	actions
static long	BARGE_WAIT_NANOS
(package private) static int	COMMITTED
(package private) static int	COMMITTING
(package private) java.util.TreeMap<Ref,java.util.ArrayList<LockingTransaction.CFn>>	commutes
(package private) java.util.HashSet<Ref>	ensures
(package private) LockingTransaction.Info	info
(package private) static int	KILLED
private static java.util.concurrent.atomic.AtomicLong	lastPoint
static int	LOCK_WAIT_MSECS
(package private) long	readPoint
(package private) static int	RETRY
static int	RETRY_LIMIT
(package private) LockingTransaction.RetryEx	retryex
(package private) static int	RUNNING
(package private) java.util.HashSet<Ref>	sets
(package private) long	startPoint
(package private) long	startTime
(package private) static java.lang.ThreadLocal<LockingTransaction>	transaction
(package private) java.util.HashMap<Ref,java.lang.Object>	vals

Constructor Summary

Constructors

Constructor and Description
LockingTransaction()

Method Summary

Methods

Modifier and Type	Method and Description
(package private) void	abort()
private boolean	barge(LockingTransaction.Info refinfo)
private boolean	bargeTimeElapsed()
private java.lang.Object	blockAndBail(LockingTransaction.Info refinfo)
(package private) java.lang.Object	doCommute(Ref ref, IFn fn, ISeq args)
(package private) void	doEnsure(Ref ref)
(package private) java.lang.Object	doGet(Ref ref)
(package private) java.lang.Object	doSet(Ref ref, java.lang.Object val)
void	enqueue(Agent.Action action)
(package private) long	getCommitPoint()
(package private) static LockingTransaction	getEx()
(package private) void	getReadPoint()
(package private) static LockingTransaction	getRunning()
static boolean	isRunning()
(package private) java.lang.Object	lock(Ref ref)
private void	releaseIfEnsured(Ref ref)
(package private) java.lang.Object	run(java.util.concurrent.Callable fn)
static java.lang.Object	runInTransaction(java.util.concurrent.Callable fn)
(package private) void	stop(int status)
(package private) void	tryWriteLock(Ref ref)

Methods inherited from class java.lang.Object

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

Field Detail

RETRY_LIMIT

public static final int RETRY_LIMIT

See Also:

Constant Field Values

LOCK_WAIT_MSECS

public static final int LOCK_WAIT_MSECS

See Also:

Constant Field Values

BARGE_WAIT_NANOS

public static final long BARGE_WAIT_NANOS

See Also:

Constant Field Values

RUNNING

static final int RUNNING

See Also:

Constant Field Values

COMMITTING

static final int COMMITTING

See Also:

Constant Field Values

RETRY

static final int RETRY

See Also:

Constant Field Values

KILLED

static final int KILLED

See Also:

Constant Field Values

COMMITTED

static final int COMMITTED

See Also:

Constant Field Values

transaction

static final java.lang.ThreadLocal<LockingTransaction> transaction

lastPoint

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

info

LockingTransaction.Info info

readPoint

long readPoint

startPoint

long startPoint

startTime

long startTime

retryex

final LockingTransaction.RetryEx retryex

actions

final java.util.ArrayList<Agent.Action> actions

vals

final java.util.HashMap<Ref,java.lang.Object> vals

sets

final java.util.HashSet<Ref> sets

commutes

final java.util.TreeMap<Ref,java.util.ArrayList<LockingTransaction.CFn>> commutes

ensures

final java.util.HashSet<Ref> ensures

Constructor Detail

LockingTransaction

public LockingTransaction()

Method Detail

getReadPoint

void getReadPoint()

getCommitPoint

long getCommitPoint()

stop

void stop(int status)

tryWriteLock

void tryWriteLock(Ref ref)

lock

java.lang.Object lock(Ref ref)

blockAndBail

private java.lang.Object blockAndBail(LockingTransaction.Info refinfo)

releaseIfEnsured

private void releaseIfEnsured(Ref ref)

abort

void abort()
     throws LockingTransaction.AbortException

Throws:

LockingTransaction.AbortException

bargeTimeElapsed

private boolean bargeTimeElapsed()

barge

private boolean barge(LockingTransaction.Info refinfo)

getEx

static LockingTransaction getEx()

isRunning

public static boolean isRunning()

getRunning

static LockingTransaction getRunning()

runInTransaction

public static java.lang.Object runInTransaction(java.util.concurrent.Callable fn)
                                         throws java.lang.Exception

Throws:

java.lang.Exception

run

java.lang.Object run(java.util.concurrent.Callable fn)
               throws java.lang.Exception

Throws:

java.lang.Exception

enqueue

public void enqueue(Agent.Action action)

doGet

java.lang.Object doGet(Ref ref)

doSet

java.lang.Object doSet(Ref ref,
                     java.lang.Object val)

doEnsure

void doEnsure(Ref ref)

doCommute

java.lang.Object doCommute(Ref ref,
                         IFn fn,
                         ISeq args)