Performs a transactional read and checks that it is consistent with all
reads already made by txn.
Performs a transactional read and checks that it is consistent with all
reads already made by txn. Equivalent to apply(), which is more
concise in many situations.
an active transaction.
the value of the Ref as observed by txn.
if txn is not active.
Returns f(get), possibly reevaluating f to avoid rollback if a
conflicting change is made but the old and new values are equal after
application of f.
Returns f(get), possibly reevaluating f to avoid rollback if a
conflicting change is made but the old and new values are equal after
application of f. Requires that f(x) == f(y) if x == y.
getWith(f) is equivalent to f(relaxedGet({ f(_) == f(_) })), although
perhaps more efficient.
an idempotent function.
the result of applying f to the value contained in this Ref.
Returns true if a value is already associated with this TxnLocal in the
current transactional context, false otherwise.
Returns the same value as get, but allows the caller to determine
whether txn should be rolled back if another thread changes the value
of this Ref before txn is committed.
Returns the same value as get, but allows the caller to determine
whether txn should be rolled back if another thread changes the value
of this Ref before txn is committed. If ref.relaxedGet(equiv)
returns v0 in txn, another context changes ref to v1, and
equiv(v0, v1) == true, then txn won't be required to roll back (at
least not due to this read). If additional changes are made to ref
additional calls to the equivalence function will be made, always with
v0 as the first parameter.
equiv will always be invoked on the current thread. Extreme care
should be taken if the equivalence function accesses any Refs.
As an example, to perform a read that will not be validated during commit you can use the maximally permissive equivalence function:
val unvalidatedValue = ref.relaxedGet({ (_, _) => true })
To check view serializability rather than conflict serializability for a read:
val viewSerializableValue = ref.relaxedGet({ _ == _ }) The getWith method provides related functionality.
an equivalence function that returns true if a transaction that observed the first argument will still complete correctly, where the second argument is the actual value that should have been observed.
a value of the Ref, not necessary consistent with the rest of
the reads performed by txn.
Performs a transactional write.
Performs a transactional write. The new value will not be visible by
any other threads until (and unless) txn successfully commits.
Equivalent to update(v).
a value to store in the Ref.
if txn is not active.
Works like set(v), but returns the old value.
Works like set(v), but returns the old value.
the previous value of this Ref, as observed by txn.
if txn is not active.
Transforms the value referenced by this Ref by applying the function
f.
Transforms the value referenced by this Ref by applying the function
f. Acts like ref.set(f(ref.get)), but the execution of f may be
deferred or repeated by the STM to reduce transaction conflicts.
a function that is safe to call multiple times, and safe to call later during the transaction.
if txn is not active.
Transforms the value v referenced by this Ref by to
pf.apply(v), but only if pf.isDefinedAt(v).
Transforms the value v referenced by this Ref by to
pf.apply(v), but only if pf.isDefinedAt(v). Returns true if
a transformation was performed, false otherwise. pf.apply and
pf.isDefinedAt may be deferred or repeated by the STM to reduce
transaction conflicts.
a partial function that is safe to call multiple times, and safe to call later in the transaction.
pf.isDefinedAt(v), where v was the value of this Ref
before transformation (if any).
if txn is not active.
Performs a transactional write and returns true, or returns false.
Performs a transactional write and returns true, or returns false. The STM implementation may choose to return false to reduce (not necessarily avoid) blocking. If no other threads are performing any transactional or atomic accesses then this method will succeed.
Transforms the value stored in the Ref by multiplying it.
Transforms the value stored in the Ref by multiplying it.
Note: Implementations may choose to ignore the provided Numeric[A]
instance if A is a primitive type.
the quantity by which to multiply the value of this Ref.
if txn is not active.
Transforms the value stored in the Ref by incrementing it.
Transforms the value stored in the Ref by incrementing it.
Note: Implementations may choose to ignore the provided Numeric[A]
instance if A is a primitive type.
the quantity by which to increment the value of this Ref.
if txn is not active.
Transforms the value stored in the Ref by decrementing it.
Transforms the value stored in the Ref by decrementing it.
Note: Implementations may choose to ignore the provided Numeric[A]
instance if A is a primitive type.
the quantity by which to decrement the value of this Ref.
if txn is not active.
Transforms the value stored the Ref by performing a division on it,
throwing away the remainder if division is not exact for instances of
type A.
Transforms the value stored the Ref by performing a division on it,
throwing away the remainder if division is not exact for instances of
type A. The careful reader will note that division is actually
provided by Fractional[A] or Integral[A], it is not defined on
Numeric[A]. To avoid compile-time ambiguity this method accepts a
Numeric[A] and assumes that it can be converted at runtime into
either a Fractional[A] or an Integral[A].
Note: Implementations may choose to ignore the provided Numeric[A]
instance if A is a primitive type.
the quantity by which to divide the value of this Ref.
if txn is not active.
Performs a transactional read and checks that it is consistent with all
reads already made by txn.
Performs a transactional read and checks that it is consistent with all
reads already made by txn. Equivalent to get.
Example:
val x = Ref(0) atomic { implicit t => ... val v = x() // perform a read inside a transaction ... }
an active transaction.
the value of the Ref as observed by txn.
if txn is not active.
Transforms the value referenced by this Ref by applying the function
f, and returns the previous value.
Transforms the value referenced by this Ref by applying the function
f, and returns the previous value.
a function that is safe to call multiple times.
the previous value of this Ref (the value passed to f).
if txn is not active.
Transforms the value referenced by this Ref from v to
f(v)._1, and returns f(v)._2.
Transforms the value referenced by this Ref from v to
f(v)._1, and returns f(v)._2.
a function that is safe to call multiple times.
the second element of the pair returned by f.
if txn is not active.
Transforms the value referenced by this Ref by applying the function
f, and returns the new value.
Transforms the value referenced by this Ref by applying the function
f, and returns the new value.
a function that is safe to call multiple times.
the new value of this Ref (the value returned from f).
if txn is not active.
Performs a transactional write.
Performs a transactional write. The new value will not be visible by
any other threads until (and unless) txn successfully commits.
Equivalent to set(v).
Example:
val x = Ref(0) atomic { implicit t => ... x() = 10 // perform a write inside a transaction ... }
a value to store in the Ref.
if txn is not active.
TxnLocal[A]holds an instance ofAthat is local to an atomic block. See the factory method in the companion object for information about the life-cycle.