E - public class GammaTxnRef<E> extends BaseGammaTxnRef implements TxnRef<E>
long_value, ref_value, type___unsafe, identityHashCode, listeners, listenersOffset, MASK_OREC_EXCLUSIVELOCK, MASK_OREC_READBIASED, MASK_OREC_READLOCKS, MASK_OREC_READONLY_COUNT, MASK_OREC_SURPLUS, MASK_OREC_UPDATELOCK, orec, stm, valueOffset, versionFAILURE, MASK_CONFLICT, MASK_SUCCESS, MASK_UNREGISTERED, REGISTRATION_DONE, REGISTRATION_NONE, REGISTRATION_NOT_NEEDED, TRANLOCAL_COMMUTING, TRANLOCAL_CONSTRUCTING, TRANLOCAL_READ, TRANLOCAL_WRITE, TRANSACTIONTYPE_FAT_FIXED_LENGTH, TRANSACTIONTYPE_FAT_MONO, TRANSACTIONTYPE_FAT_VARIABLE_LENGTH, TRANSACTIONTYPE_LEAN_FIXED_LENGTH, TRANSACTIONTYPE_LEAN_MONO, TX_ABORTED, TX_ACTIVE, TX_COMMITTED, TX_PREPARED, TYPE_BOOLEAN, TYPE_DOUBLE, TYPE_INT, TYPE_LONG, TYPE_REF, VERSION_UNCOMMITTEDLOCKMODE_EXCLUSIVE, LOCKMODE_NONE, LOCKMODE_READ, LOCKMODE_WRITE, SHAKE_BUGS, SPIN_YIELD, TRACING_ENABLED| Constructor and Description |
|---|
GammaTxnRef(E value) |
GammaTxnRef(GammaStm stm) |
GammaTxnRef(GammaStm stm,
E value) |
GammaTxnRef(GammaTxn tx) |
GammaTxnRef(GammaTxn tx,
E value) |
| Modifier and Type | Method and Description |
|---|---|
E |
alterAndGet(Function<E> function)
Alters the value stored in this Ref using the provided function and returns the result.
|
E |
alterAndGet(GammaTxn tx,
Function<E> function) |
E |
alterAndGet(Txn tx,
Function<E> function)
Alters the value stored in this Ref using the provided function and lifting on the provided txn.
|
E |
atomicAlterAndGet(Function<E> function)
Atomically applies the function to the current value in this ref and returns the new value.
|
boolean |
atomicCompareAndSet(E expectedValue,
E newValue)
Executes a compare and set atomically.
|
E |
atomicGet()
Atomically gets the value.
|
E |
atomicGetAndAlter(Function<E> function)
Atomically applies the function to alter the value stored in this ref and returns the old value.
|
E |
atomicGetAndSet(E newValue)
Atomically sets the value and returns the previous value.
|
boolean |
atomicIsNull()
Atomically check if the current value is null.
|
E |
atomicSet(E newValue)
Atomically sets the value and returns the new value.
|
java.lang.String |
atomicToString()
Returns a String representation of the object using the provided transaction without looking
at a
TxnThreadLocal. |
E |
atomicWeakGet()
Atomically gets the value without providing any ordering guarantees.
|
void |
await(E value)
Awaits for the value to become the given value.
|
void |
await(GammaTxn tx,
E value) |
void |
await(GammaTxn tx,
Predicate<E> predicate) |
void |
await(Predicate<E> predicate)
Awaits until the predicate holds.
|
void |
await(Txn tx,
E value)
Awaits for the reference to become the given value.
|
void |
await(Txn tx,
Predicate<E> predicate)
Awaits until the predicate holds using the provided txn.
|
E |
awaitNotNullAndGet()
Awaits for the value to become not null.
|
E |
awaitNotNullAndGet(GammaTxn tx) |
E |
awaitNotNullAndGet(Txn tx)
Awaits for the value to become not null using the provided txn.
|
void |
awaitNull()
Awaits for the value to become null.
|
void |
awaitNull(GammaTxn tx) |
void |
awaitNull(Txn tx)
Awaits for the value to become not null using the provided txn.
|
void |
commute(Function<E> function)
Applies the function on the ref in a commuting manner.
|
void |
commute(GammaTxn tx,
Function<E> function) |
void |
commute(Txn tx,
Function<E> function)
Applies the function on the ref in a commuting manner.
|
E |
get()
Gets the value using the provided txn.
|
E |
get(GammaTxn tx) |
E |
get(Txn tx)
Gets the value using the provided txn.
|
E |
getAndAlter(Function<E> function)
Alters the value stored in this Ref using the provided function amd returns the old value.
|
E |
getAndAlter(GammaTxn tx,
Function<E> function) |
E |
getAndAlter(Txn tx,
Function<E> function)
Alters the value stored in this Ref using the function and returns the old value, using the provided txn.
|
E |
getAndLock(GammaTxn tx,
LockMode lockMode) |
E |
getAndLock(LockMode lockMode)
Gets the value and applies the lock.
|
E |
getAndLock(Txn tx,
LockMode lockMode)
Gets the value using the provided txn and acquired the lock with the specified LockMode.
|
E |
getAndSet(E value)
Sets the value the value and returns the new value.
|
E |
getAndSet(GammaTxn tx,
E value) |
E |
getAndSet(Txn tx,
E value)
Sets the value using the provided txn.
|
E |
getAndSetAndLock(E value,
LockMode lockMode)
Sets the value, acquired the Lock with the specified Lockmode and returns the previous value.
|
E |
getAndSetAndLock(GammaTxn tx,
E value,
LockMode lockMode) |
E |
getAndSetAndLock(Txn tx,
E value,
LockMode lockMode)
Sets the value and acquired the Lock with the provided LockMode.
|
boolean |
isNull()
Checks if the current value is null.
|
boolean |
isNull(GammaTxn tx) |
boolean |
isNull(Txn tx)
Checks if the current value is null using the provided txn.
|
E |
set(E value)
Sets the new value.
|
E |
set(GammaTxn tx,
E value) |
E |
set(Txn tx,
E value)
Sets the new value using the provided txn.
|
E |
setAndLock(E value,
LockMode lockMode)
Sets the new value and applies the lock.
|
E |
setAndLock(GammaTxn tx,
E value,
LockMode lockMode) |
E |
setAndLock(Txn tx,
E value,
LockMode lockMode)
Sets the new value using the provided txn.
|
java.lang.String |
toDebugString()
Returns a debug representation of the TxnObject.
|
java.lang.String |
toString()
Returns a String representation of the Object using the
Txn on the TxnThreadLocal. |
java.lang.String |
toString(GammaTxn tx) |
java.lang.String |
toString(Txn tx)
Returns a String representation of the object using the provided
Txn. |
acquire, acquire, acquire, arriveAndExclusiveLockOrBackoff, atomicCompareAndSetLong, atomicGetLong, atomicObjectGet, atomicSetLong, atomicSetObject, commit, ensure, ensure, ensure, flattenCommute, getLong, getObject, hasReadConflict, leanCommit, load, openForCommute, openForCommute, openForCommute, openForCommute, openForConstruction, openForConstruction, openForConstruction, openForConstruction, openForRead, openForRead, openForRead, openForRead, openForRead, openForRead, openForWrite, openForWrite, openForWrite, openForWrite, openForWrite, openForWrite, prepare, registerChangeListener, releaseAfterFailure, releaseAfterReading, releaseAfterUpdate, setLong, setObject, tryLockAndCheckConflict___removeListenersAfterWrite, ___toOrecString, arrive, arriveAndExclusiveLock, arriveAndLock, atomicGetLockMode, atomicGetLockModeAsInt, departAfterFailure, departAfterFailureAndUnlock, departAfterReading, departAfterReadingAndUnlock, departAfterUpdateAndUnlock, getLock, getLockMode, getLockMode, getLockMode, getReadBiasedThreshold, getReadLockCount, getReadLockCount, getReadonlyCount, getReadonlyCount, getStm, getSurplus, getSurplus, getVersion, hasAnyLock, hasExclusiveLock, hasExclusiveLock, hasWriteLock, hasWriteLock, hasWriteOrExclusiveLock, identityHashCode, isReadBiased, isReadBiased, lockAfterArrive, setExclusiveLock, setIsReadBiased, setReadLockCount, setReadonlyCount, setSurplus, setWriteLock, unlockByUnregistered, upgradeReadLock, upgradeWriteLock, waitForExclusiveLockToBecomeFreepublic GammaTxnRef(E value)
public GammaTxnRef(GammaTxn tx)
public GammaTxnRef(GammaStm stm)
public final E get()
TxnRefget in interface TxnRef<E>TxnRef.atomicGet()public final E get(Txn tx)
TxnRefpublic final E getAndLock(LockMode lockMode)
TxnRefThis call lifts on the Txn stored in the TxnThreadLocal.
getAndLock in interface TxnRef<E>lockMode - the LockMode applied.TxnRef.atomicGet()public final E getAndLock(Txn tx, LockMode lockMode)
TxnRefgetAndLock in interface TxnRef<E>tx - the Txn used for this operation.lockMode - the LockMode usedpublic final E set(E value)
TxnRefThis call lifts on the Txn stored in the TxnThreadLocal.
public final E set(Txn tx, E value)
TxnRefpublic final E setAndLock(E value, LockMode lockMode)
TxnRefThis call lifts on the Txn stored in the TxnThreadLocal.
setAndLock in interface TxnRef<E>value - the new value.lockMode - the used LockMode.public final E setAndLock(Txn tx, E value, LockMode lockMode)
TxnRefsetAndLock in interface TxnRef<E>tx - the Txn used for this operation.value - the new valuelockMode - the lockMode used.public final E getAndSet(E value)
TxnRefThis call lifts on the Txn stored in the TxnThreadLocal.
public final E getAndSet(Txn tx, E value)
TxnRefpublic final E getAndSetAndLock(E value, LockMode lockMode)
TxnRefThis call lifts on the Txn stored in the TxnThreadLocal.
getAndSetAndLock in interface TxnRef<E>value - the new value.lockMode - the LockMode used.public final E getAndSetAndLock(Txn tx, E value, LockMode lockMode)
TxnRefThis call lifts on the Txn stored in the TxnThreadLocal.
getAndSetAndLock in interface TxnRef<E>tx - the Txn used for this operation.value - the new value.lockMode - the LockMode used.public final E atomicGet()
TxnRefTxnRef.atomicWeakGet().public final E atomicWeakGet()
TxnRefIt is the best method to call if you just want to get the current value stored.
atomicWeakGet in interface TxnRef<E>public final E atomicSet(E newValue)
TxnRefpublic final E atomicGetAndSet(E newValue)
TxnRefatomicGetAndSet in interface TxnRef<E>newValue - the new value.public final void commute(Function<E> function)
TxnRefThis is different than the behavior in Clojure where the commute will be re-applied at the end of the txn, even though some dependency is introduced, which can lead to inconsistencies.
This call lifts on the Txn stored in the TxnThreadLocal.
public final void commute(Txn tx, Function<E> function)
TxnRefThis is different than the behavior in Clojure where the commute will be re-applied at the end of the txn, even though some dependency is introduced, which can lead to inconsistencies.
This call lifts on the Txn stored in the TxnThreadLocal.
public final E atomicAlterAndGet(Function<E> function)
TxnRefatomicAlterAndGet in interface TxnRef<E>function - the Function usedpublic final E atomicGetAndAlter(Function<E> function)
TxnRefatomicGetAndAlter in interface TxnRef<E>function - the Function usedpublic final E alterAndGet(Function<E> function)
TxnRefThis call lifts on the Txn stored in the TxnThreadLocal.
alterAndGet in interface TxnRef<E>function - the function that alters the value stored in this Ref.public final E alterAndGet(Txn tx, Function<E> function)
TxnRefalterAndGet in interface TxnRef<E>tx - the Txn used for this operation.function - the function that alters the value stored in this Ref.public final E getAndAlter(Function<E> function)
TxnRefThis call lifts on the Txn stored in the TxnThreadLocal.
getAndAlter in interface TxnRef<E>function - the function that alters the value stored in this Ref.public final E getAndAlter(Txn tx, Function<E> function)
TxnRefgetAndAlter in interface TxnRef<E>tx - the Txn used for this operation.function - the function that alters the value stored in this Ref.public final boolean atomicCompareAndSet(E expectedValue, E newValue)
TxnRefatomicCompareAndSet in interface TxnRef<E>expectedValue - the expected value.newValue - the new value.public final boolean isNull()
TxnRefThis call lifts on the Txn stored in the TxnThreadLocal.
public final boolean isNull(Txn tx)
TxnRefpublic final boolean isNull(GammaTxn tx)
public final boolean atomicIsNull()
TxnRefatomicIsNull in interface TxnRef<E>public final E awaitNotNullAndGet()
TxnRefThis call lifts on the Txn stored in the TxnThreadLocal.
awaitNotNullAndGet in interface TxnRef<E>public final E awaitNotNullAndGet(Txn tx)
TxnRefawaitNotNullAndGet in interface TxnRef<E>tx - the Txn used for this operation.public final void awaitNull()
TxnRefThis call lifts on the Txn stored in the TxnThreadLocal.
public final void awaitNull(Txn tx)
TxnRefpublic final void awaitNull(GammaTxn tx)
public final void await(E value)
TxnRefThis call lifts on the Txn stored in the TxnThreadLocal.
public final void await(Txn tx, E value)
TxnRefpublic final void await(Predicate<E> predicate)
TxnRefThis call lifts on the Txn stored in the TxnThreadLocal.
public final void await(Txn tx, Predicate<E> predicate)
TxnRefpublic final java.lang.String toDebugString()
TxnObjecttoDebugString in interface TxnObjectpublic final java.lang.String toString()
TxnObjectTxn on the TxnThreadLocal.public final java.lang.String toString(Txn tx)
TxnObjectTxn.public final java.lang.String toString(GammaTxn tx)
public final java.lang.String atomicToString()
TxnObjectTxnThreadLocal. The outputted value doesn't need to be consistent from some point
in time, only a best effort is made.atomicToString in interface TxnObject