class AsyncMutex extends AsyncSemaphore

An AsyncMutex is a traditional mutex but with asynchronous execution.

Basic usage:

val mutex = new AsyncMutex()
...
mutex.acquireAndRun() {
  somethingThatReturnsFutureT()
}
See also

AsyncSemaphore for a semaphore version.

Linear Supertypes
AsyncSemaphore, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. AsyncMutex
  2. AsyncSemaphore
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new AsyncMutex(maxWaiters: Int)

    Constructs a mutex with maxWaiters as the limit on the number of waiters for permits.

  2. new AsyncMutex()

    Constructs a mutex with no limit on the max number of waiters for permits.

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 acquire(): Future[Permit]

    Acquire a Permit, asynchronously.

    Acquire a Permit, asynchronously. Be sure to permit.release() in a

    - finally block of your onSuccess callback - ensure block of your future chain

    Interrupting this future is only advisory, and will not release the permit if the future has already been satisfied.

    returns

    a Future[Permit] when the Future is satisfied, computation can proceed, or a Future.Exception[RejectedExecutionException] if the configured maximum number of waiters would be exceeded.

    Definition Classes
    AsyncSemaphore
    Note

    This method always return the same instance of Permit.

  5. def acquireAndRun[T](func: => Future[T]): Future[T]

    Execute the function asynchronously when a permit becomes available.

    Execute the function asynchronously when a permit becomes available.

    If the function throws a non-fatal exception, the exception is returned as part of the Future. For all exceptions, the permit would be released before returning.

    returns

    a Future[T] equivalent to the return value of the input function. If the configured maximum value of waitq is reached, Future.Exception[RejectedExecutionException] is returned.

    Definition Classes
    AsyncSemaphore
  6. def acquireAndRunSync[T](func: => T): Future[T]

    Execute the function when a permit becomes available.

    Execute the function when a permit becomes available.

    If the function throws an exception, the exception is returned as part of the Future. For all exceptions, the permit would be released before returning.

    returns

    a Future[T] equivalent to the return value of the input function. If the configured maximum value of waitq is reached, Future.Exception[RejectedExecutionException] is returned.

    Definition Classes
    AsyncSemaphore
  7. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  8. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native()
  9. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  10. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  11. def fail(exc: Throwable): Unit

    Fail the semaphore and stop it from distributing further permits.

    Fail the semaphore and stop it from distributing further permits. Subsequent attempts to acquire a permit fail with exc. This semaphore's queued waiters are also failed with exc.

    Definition Classes
    AsyncSemaphore
  12. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable])
  13. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  14. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  15. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  16. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  17. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  18. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  19. def numInitialPermits: Int
    Definition Classes
    AsyncSemaphore
  20. def numPermitsAvailable: Int
    Definition Classes
    AsyncSemaphore
  21. def numWaiters: Int
    Definition Classes
    AsyncSemaphore
  22. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  23. def toString(): String
    Definition Classes
    AnyRef → Any
  24. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  25. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  26. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()

Inherited from AsyncSemaphore

Inherited from AnyRef

Inherited from Any

Ungrouped