Packages

object WorkerPools

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

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. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native() @IntrinsicCandidate()
  6. implicit def currentExecutionContext: ExecutionContext
  7. implicit def currentPool: Option[WorkerPool]

    returns

    Some if the current thread is a member of a WorkerPool, None instead

  8. def currentTask: Option[WorkerTask[_]]
  9. def currentTaskWithController: Option[WorkerTask[_] with AsyncTaskController]
  10. def currentWorker: Worker
  11. def currentWorkerOpt: Option[Worker]
  12. def ensureCurrentIsNotWorker(): Unit

    Exceptions thrown

    IllegalThreadException if the current thread is not a Worker

  13. def ensureCurrentIsNotWorker(msg: String): Unit

    msg

    the message to complain with the exception

    Exceptions thrown

    IllegalThreadException if the current thread is not a Worker

  14. def ensureCurrentIsWorker(): WorkerPool

    Exceptions thrown

    IllegalThreadException if the current thread is a Worker

  15. def ensureCurrentIsWorker(msg: String): WorkerPool

    msg

    the message to complain with the exception

    Exceptions thrown

    IllegalThreadException if the current thread is a Worker

  16. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  17. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  18. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @IntrinsicCandidate()
  19. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @IntrinsicCandidate()
  20. def ifCurrentWorkerOrElse[A](ifCurrent: (WorkerPool) => A, orElse: => A): A

    Toggles between two actions if the current thread is an instance of Worker

    Toggles between two actions if the current thread is an instance of Worker

    ifCurrent

    The action to process if the current thread is a worker thread. The given entry is the current thread pool

    orElse

    the action to process if the current thread is not a worker thread.

  21. def isCurrentThreadWorker: Boolean

    returns

    true
  22. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  23. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  24. def newClosedPool(name: String, initialThreadCount: Int = 0): ClosedWorkerPool
  25. def newHiringPool(name: String): HiringWorkerPool
  26. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @IntrinsicCandidate()
  27. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @IntrinsicCandidate()
  28. def runLaterInCurrentPool(action: => Unit): Unit
  29. def runLaterOrHere(action: => Unit): Unit

    This method may execute the given action into the current thread pool.

    This method may execute the given action into the current thread pool. If the current execution thread is not a worker thread, this would mean that we are not running into a thread that is owned by the concurrency system. Therefore, the action may be performed in the current thread

    action

    the action to perform

  30. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  31. def toString(): String
    Definition Classes
    AnyRef → Any
  32. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  33. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  34. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated
    Deprecated

Inherited from AnyRef

Inherited from Any

Ungrouped