class ThreadPoolIdlenessExecutorService extends ExecutorServiceDelegate with ExecutionContextIdlenessExecutorService
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- ThreadPoolIdlenessExecutorService
- ExecutionContextIdlenessExecutorService
- IdlenessExecutorService
- ExecutorServiceDelegate
- ExecutionContextExecutorService
- ExecutorService
- ExecutionContextExecutor
- Executor
- ExecutionContext
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Instance Constructors
- new ThreadPoolIdlenessExecutorService(pool: ThreadPoolExecutor, reporter: (Throwable) => Unit, 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
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def awaitIdleness(timeout: FiniteDuration): Boolean
Waits until all threads in the executor service are idle.
Waits until all threads in the executor service are idle. The current thread may help in processing submitted tasks. The method may be conservative: it can return false even if all threads are idle at the end of the
duration.- timeout
The maximum time to wait. This time may be exceeded up to the run-time of the longest running task in the pool.
- returns
true if all threads are idle; false if the timeout elapsed
- Definition Classes
- IdlenessExecutorService
- Annotations
- @SuppressWarnings()
- def awaitIdlenessOnce(timeout: FiniteDuration): Boolean
- Attributes
- protected[concurrent]
- Definition Classes
- ThreadPoolIdlenessExecutorService → IdlenessExecutorService
- def awaitTermination(timeout: Long, unit: TimeUnit): Boolean
- Definition Classes
- ExecutorServiceDelegate → ExecutorService
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native() @HotSpotIntrinsicCandidate()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def execute(command: Runnable): Unit
- Definition Classes
- ExecutorServiceDelegate → Executor → ExecutionContext
- val executorService: ExecutorService
- Definition Classes
- ExecutorServiceDelegate
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def invokeAll[T](tasks: Collection[_ <: Callable[T]], timeout: Long, unit: TimeUnit): List[Future[T]]
- Definition Classes
- ExecutorServiceDelegate → ExecutorService
- def invokeAll[T](tasks: Collection[_ <: Callable[T]]): List[Future[T]]
- Definition Classes
- ExecutorServiceDelegate → ExecutorService
- def invokeAny[T](tasks: Collection[_ <: Callable[T]], timeout: Long, unit: TimeUnit): T
- Definition Classes
- ExecutorServiceDelegate → ExecutorService
- def invokeAny[T](tasks: Collection[_ <: Callable[T]]): T
- Definition Classes
- ExecutorServiceDelegate → ExecutorService
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def isShutdown(): Boolean
- Definition Classes
- ExecutorServiceDelegate → ExecutorService
- def isTerminated(): Boolean
- Definition Classes
- ExecutorServiceDelegate → ExecutorService
- val name: String
- Definition Classes
- ThreadPoolIdlenessExecutorService → ExecutionContextIdlenessExecutorService
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def queueSize: Int
Return the thread pool's queue size.
Return the thread pool's queue size.
- Definition Classes
- ThreadPoolIdlenessExecutorService → IdlenessExecutorService
- def reportFailure(cause: Throwable): Unit
- Definition Classes
- ThreadPoolIdlenessExecutorService → ExecutionContext
- def shutdown(): Unit
- Definition Classes
- ExecutorServiceDelegate → ExecutorService
- def shutdownNow(): List[Runnable]
- Definition Classes
- ExecutorServiceDelegate → ExecutorService
- def submit(task: Runnable): Future[_]
- Definition Classes
- ExecutorServiceDelegate → ExecutorService
- def submit[T](task: Runnable, result: T): Future[T]
- Definition Classes
- ExecutorServiceDelegate → ExecutorService
- def submit[T](task: Callable[T]): Future[T]
- Definition Classes
- ExecutorServiceDelegate → ExecutorService
- 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])
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