object EngineWorkerPools extends Provider
- Alphabetic
- By Inheritance
- EngineWorkerPools
- Provider
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def bindWorker(thread: Thread, workerVersion: Worker): Unit
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native() @IntrinsicCandidate()
- implicit def currentExecutionContext: ExecutionContext
- Definition Classes
- EngineWorkerPools → Provider
- implicit def currentPool: Option[WorkerPool]
- returns
Some if the current thread is a member of a WorkerPool, None instead
- Definition Classes
- EngineWorkerPools → Provider
- def currentTask: Option[WorkerTask[_]]
- Definition Classes
- EngineWorkerPools → Provider
- Annotations
- @workerExecution()
- def currentTaskWithController: Option[WorkerTask[_] with AsyncTaskController]
- Definition Classes
- EngineWorkerPools → Provider
- Annotations
- @workerExecution()
- def currentWorker: Worker
- Definition Classes
- EngineWorkerPools → Provider
- Annotations
- @workerExecution()
- def currentWorkerOpt: Option[Worker]
- Definition Classes
- EngineWorkerPools → Provider
- def ensureCurrentIsNotWorker(msg: String): Unit
- msg
the message to complain with the exception
- Definition Classes
- EngineWorkerPools → Provider
- Annotations
- @throws("If the current thread that executes this method is an instance of WorkerThread.")
- Exceptions thrown
IllegalThreadExceptionif the current thread is not a Worker
- def ensureCurrentIsNotWorker(): Unit
- Definition Classes
- EngineWorkerPools → Provider
- Annotations
- @throws("If the current thread that executes this method is an instance of WorkerThread.")
- Exceptions thrown
IllegalThreadExceptionif the current thread is not a Worker
- def ensureCurrentIsWorker(msg: String): WorkerPool
- msg
the message to complain with the exception
- Definition Classes
- EngineWorkerPools → Provider
- Annotations
- @throws("If the current thread that executes this method is not an instance of WorkerThread.")
- Exceptions thrown
IllegalThreadExceptionif the current thread is a Worker
- def ensureCurrentIsWorker(): WorkerPool
- Definition Classes
- EngineWorkerPools → Provider
- Annotations
- @throws("If the current thread that executes this method is not an instance of WorkerThread.")
- Exceptions thrown
IllegalThreadExceptionif the current thread is a Worker
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @IntrinsicCandidate()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @IntrinsicCandidate()
- 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.
- Definition Classes
- EngineWorkerPools → Provider
- def isCurrentThreadWorker: Boolean
- returns
true
- Definition Classes
- EngineWorkerPools → Provider
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def newClosedPool(name: String, initialThreadCount: Int = 0): ClosedWorkerPool
- Definition Classes
- EngineWorkerPools → Provider
- def newHiringPool(name: String): HiringWorkerPool
- Definition Classes
- EngineWorkerPools → Provider
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @IntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @IntrinsicCandidate()
- def runLaterInCurrentPool(action: => Unit): Unit
- Definition Classes
- EngineWorkerPools → Provider
- Annotations
- @throws("If the current thread that executes this method is not an instance of WorkerThread.")
- 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
- Definition Classes
- EngineWorkerPools → Provider
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- val workerThreadGroup: ThreadGroup
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated