akka

stm

package stm

For easily importing everything needed for STM.

Visibility
  1. Public
  2. All

Type Members

  1. class Atomic [T] extends AnyRef

    Java-friendly atomic blocks.

  2. type BooleanRef = BooleanRef

    Definition Classes
    package
  3. type ByteRef = ByteRef

    Definition Classes
    package
  4. type CharRef = CharRef

    Definition Classes
    package
  5. type DoubleRef = DoubleRef

    Definition Classes
    package
  6. class EitherOrElse [T] extends OrElseTemplate[T]

    Use EitherOrElse to combine two blocking transactions (from Java).

  7. type FloatRef = FloatRef

    Definition Classes
    package
  8. type IntRef = IntRef

    Definition Classes
    package
  9. type LongRef = LongRef

    Definition Classes
    package
  10. class Ref [T] extends BasicRef[T] with Transactional

    Refs (transactional references) are mutable references to values and through the STM allow the safe sharing of mutable data.

  11. type ShortRef = ShortRef

    Definition Classes
    package
  12. trait Stm extends AnyRef

    Defines the atomic block for local transactions.

  13. trait StmUtil extends AnyRef

    Stm utility methods for scheduling transaction lifecycle tasks and for blocking transactions.

  14. type TMap [K, V] = TransactionalMap[K, V]

    Definition Classes
    package
  15. type TVector [T] = TransactionalVector[T]

    Definition Classes
    package
  16. class TransactionConfig extends AnyRef

    For configuring multiverse transactions.

  17. class TransactionConfigBuilder extends AnyRef

    For more easily creating TransactionConfig from Java.

  18. class TransactionFactory extends AnyRef

    Wrapper for transaction config, factory, and boilerplate.

  19. class TransactionFactoryBuilder extends AnyRef

    For more easily creating TransactionFactory from Java.

  20. trait Transactional extends Serializable

    Common trait for all the transactional objects.

  21. class TransactionalMap [K, V] extends Transactional with Map[K, V]

    Transactional map that implements the mutable Map interface with an underlying Ref and HashMap.

  22. type TransactionalReferenceArray [T] = TransactionalReferenceArray[T]

    Definition Classes
    package
  23. type TransactionalThreadPoolExecutor = TransactionalThreadPoolExecutor

    Definition Classes
    package
  24. class TransactionalVector [T] extends Transactional with IndexedSeq[T]

    Transactional vector that implements the IndexedSeq interface with an underlying Ref and Vector.

Value Members

  1. object DefaultTransactionConfig extends TransactionConfig

  2. val DefaultTransactionFactory : TransactionFactory

    Definition Classes
    Stm
  3. object Propagation extends AnyRef

    Mapping to Multiverse PropagationLevel.

  4. object Ref extends Serializable

    Transactional managed reference.

  5. object Stm extends AnyRef

  6. object StmUtils extends AnyRef

    Stm utility methods for using from Java.

  7. val TMap : akka.stm.TransactionalMap.type

    Definition Classes
    package
  8. val TVector : akka.stm.TransactionalVector.type

    Definition Classes
    package
  9. object TraceLevel extends AnyRef

    Mapping to Multiverse TraceLevel.

  10. object TransactionConfig extends AnyRef

    For configuring multiverse transactions.

  11. object TransactionFactory extends AnyRef

    Wrapper for transaction config, factory, and boilerplate.

  12. object TransactionalMap extends Serializable

    Transactional map that implements the mutable Map interface with an underlying Ref and HashMap.

  13. object TransactionalVector extends Serializable

    Transactional vector that implements the IndexedSeq interface with an underlying Ref and Vector.

  14. def atomic [T] (factory: TransactionFactory)(body: ⇒ T): T

    Definition Classes
    Stm
  15. def atomic [T] (body: ⇒ T)(implicit factory: TransactionFactory = DefaultTransactionFactory): T

    Definition Classes
    Stm
  16. def compensating [T] (body: ⇒ T): Unit

    Schedule a compensating task on the thread local transaction (use within an atomic).

    Schedule a compensating task on the thread local transaction (use within an atomic). This is executed when the transaction aborts.

    Definition Classes
    StmUtil
  17. def deferred [T] (body: ⇒ T): Unit

    Schedule a deferred task on the thread local transaction (use within an atomic).

    Schedule a deferred task on the thread local transaction (use within an atomic). This is executed when the transaction commits.

    Definition Classes
    StmUtil
  18. def either [T] (firstBody: ⇒ T): AnyRef { def orElse(secondBody: => T): T }

    Use either-orElse to combine two blocking transactions.

    Use either-orElse to combine two blocking transactions.

    Definition Classes
    StmUtil
  19. def retry (): Unit

    STM retry for blocking transactions (use within an atomic).

    STM retry for blocking transactions (use within an atomic). Can be used to wait for a condition.

    Definition Classes
    StmUtil