object TxnLocal

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. TxnLocal
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. def apply[A](init: ⇒ A = null.asInstanceOf[A], initialValue: (InTxn) ⇒ A = null, beforeCommit: (InTxn) ⇒ Unit = null, whilePreparing: (InTxnEnd) ⇒ Unit = null, whileCommitting: (InTxnEnd) ⇒ Unit = null, afterCommit: (A) ⇒ Unit = null, afterRollback: (Status) ⇒ Unit = null, afterCompletion: (Status) ⇒ Unit = null): TxnLocal[A]

    Returns a new transaction-local that holds values of type A.

    Returns a new transaction-local that holds values of type A. One TxnLocal instance holds a separate value for each transaction in which it has been accessed. The value associated with a particular atomic block is created on demand, and discarded at the same time that the atomic block's after-completion handlers are invoked. TxnLocal has a similar relationship to transactions as ThreadLocal has to threads.

    There are two ways to specify the initial value that will be used if the first access inside a transaction is not a set. If no InTxn context is needed to compute the initial value then the by-name parameter init is the most convenient. Because this is the first parameter, you can omit the parameter name. To construct a TxnLocal with a default value of aValue, simply

    val tl = TxnLocal(aValue)

    If computing the initial value requires access to Refs, then it is better to use the initialValue parameter, which lets you write

    val tl = TxnLocal(initialValue = { implicit txn =>
      // Ref reads or writes, or handler registration
    })

    Unlike Refs, TxnLocals can be read or written from inside while-preparing or while-committing callbacks, with two conditions: if the first access is from one of these callbacks then no beforeCommit parameter can be present; and if the first access is from one of these callbacks and it is not a write then you must use the init initialization method.

    This factory method also accepts parameters that correspond to Txn's transaction life-cycle handlers. These handlers will be registered in any transaction that reads or writes the returned TxnLocal. They are roughly

    • beforeCommit - the last time that Refs can be read or written;
    • whilePreparing - the last time that the transaction can be rolled back;
    • whileCommitting - actions that should be atomic with respect to the transaction (keep them fast to avoid scalability issues);
    • afterCommit - called at some time after commit;
    • afterRollback - called at some time after rollback of the nesting level in which the TxnLocal was first accessed; and
    • afterCompletion - called either after commit or after rollback.

    The value stored in a TxnLocal is subject to partial rollback: initial value computations and writes from a nested atomic block will be discarded if the block is rolled back.

  5. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  6. def clone(): AnyRef
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  7. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  8. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  9. def finalize(): Unit
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  10. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
  11. def hashCode(): Int
    Definition Classes
    AnyRef → Any
  12. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  13. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  14. final def notify(): Unit
    Definition Classes
    AnyRef
  15. final def notifyAll(): Unit
    Definition Classes
    AnyRef
  16. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  17. def toString(): String
    Definition Classes
    AnyRef → Any
  18. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  19. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  20. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from AnyRef

Inherited from Any

Ungrouped