class SimpleClosedWorkerPool extends AbstractWorkerPool with ClosedWorkerPool
- Alphabetic
- By Inheritance
- SimpleClosedWorkerPool
- ClosedWorkerPool
- AbstractWorkerPool
- Closeable
- AutoCloseable
- WorkerPool
- ExecutionContext
- ProcrastinatorControl
- Procrastinator
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new SimpleClosedWorkerPool(initialThreadCount: Int, name: String)
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
- def addWorker(worker: Worker): Unit
- Attributes
- protected
- Definition Classes
- AbstractWorkerPool
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native() @IntrinsicCandidate()
- def close(): Unit
- Definition Classes
- SimpleClosedWorkerPool → AbstractWorkerPool → Closeable → AutoCloseable
- var closed: Boolean
- Attributes
- protected
- Definition Classes
- AbstractWorkerPool
- def countRemainingTasks: Int
- Attributes
- protected
- Definition Classes
- SimpleClosedWorkerPool → AbstractWorkerPool
- def currentTaskExecutionDepth: Int
The Task Execution Depth is an int value that determines the number of tasks a thread is consequently executing.
The Task Execution Depth is an int value that determines the number of tasks a thread is consequently executing.
- returns
the task execution depth of the current thread
- Definition Classes
- AbstractWorkerPool
- Annotations
- @workerExecution()
- Exceptions thrown
IllegalThreadExceptionif the current thread is not a Worker
- def ensureCurrentThreadNotOwned(msg: String): Unit
- Definition Classes
- AbstractWorkerPool
- def ensureCurrentThreadNotOwned(): Unit
- Definition Classes
- AbstractWorkerPool
- def ensureCurrentThreadOwned(msg: String): Unit
- Definition Classes
- AbstractWorkerPool → WorkerPool
- def ensureCurrentThreadOwned(): Unit
- Definition Classes
- AbstractWorkerPool → WorkerPool
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def execute(runnable: Runnable): Unit
- Definition Classes
- AbstractWorkerPool → ExecutionContext
- def executeRemainingTasks(): Unit
- Definition Classes
- AbstractWorkerPool
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @IntrinsicCandidate()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @IntrinsicCandidate()
- final def haveMoreTasks: Boolean
- Definition Classes
- AbstractWorkerPool
- def isCurrentThreadOwned: Boolean
- Definition Classes
- AbstractWorkerPool → WorkerPool
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- val name: String
- Definition Classes
- AbstractWorkerPool → WorkerPool
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def newBusyQueue[A]: BlockingQueue[A]
Creates a blocking queue that keep busy its thread instead of make it waiting the provided queue will use the busy threading system for concurrent operations such as BlockingQueue#take()
Creates a blocking queue that keep busy its thread instead of make it waiting the provided queue will use the busy threading system for concurrent operations such as BlockingQueue#take()
- A
the type of element the queue will contains
- returns
- Definition Classes
- AbstractWorkerPool → WorkerPool
- def nextTaskCount: Int
- Definition Classes
- SimpleClosedWorkerPool → AbstractWorkerPool
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @IntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @IntrinsicCandidate()
- def pauseCurrentTask(lock: Lock): Unit
pauses the current task and look for executing other pending tasks while this task is paused
pauses the current task and look for executing other pending tasks while this task is paused
- lock
a lock to acquire until the current task is marked as paused.
- Definition Classes
- AbstractWorkerPool → WorkerPool
- Annotations
- @workerExecution()
- Exceptions thrown
IllegalThreadExceptionif the current thread is not a Worker
- def pauseCurrentTask(): Unit
- Definition Classes
- AbstractWorkerPool → WorkerPool
- def pauseCurrentTaskForAtLeast(timeoutMillis: Long): Unit
Keep the current thread busy with task execution for at least x milliseconds.
Keep the current thread busy with task execution for at least x milliseconds.
- timeoutMillis
the number of milliseconds the thread must be busy.
- Definition Classes
- AbstractWorkerPool → WorkerPool
- Exceptions thrown
IllegalThreadExceptionif the current thread is not a Worker
- def pollTask: Runnable
- Attributes
- protected
- Definition Classes
- SimpleClosedWorkerPool → AbstractWorkerPool
- def post(runnable: Runnable): Unit
- Attributes
- protected
- Definition Classes
- SimpleClosedWorkerPool → AbstractWorkerPool
- def reportFailure(cause: Throwable): Unit
- Definition Classes
- AbstractWorkerPool → ExecutionContext
- def runLater(task: => Unit): Unit
- Definition Classes
- AbstractWorkerPool → Procrastinator
- def runLaterControl[A](task: => A): WorkerTask[A]
Submits a task to the executor thread pool.
Submits a task to the executor thread pool. The task will then be handled directly or right after a thread is looking for other task to schedule.
- task
the task to execute in the thread pool
- Definition Classes
- AbstractWorkerPool → ProcrastinatorControl
- Exceptions thrown
IllegalStateExceptionif the pool is closed
- def setThreadCount(newCount: Int): Unit
- Definition Classes
- SimpleClosedWorkerPool → ClosedWorkerPool
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def takeTask: Runnable
- Attributes
- protected
- Definition Classes
- SimpleClosedWorkerPool → AbstractWorkerPool
- def threadCount: Int
- Attributes
- protected
- Definition Classes
- AbstractWorkerPool
- 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 workers: ListBuffer[Worker]
- Attributes
- protected
- Definition Classes
- AbstractWorkerPool
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
- def prepare(): ExecutionContext
- Definition Classes
- ExecutionContext
- Annotations
- @deprecated
- Deprecated
(Since version 2.12.0) preparation of ExecutionContexts will be removed