abstract class ExecutionContextIdlenessExecutorService extends QueueAwareExecutorService with IdlenessExecutorService with ExecutionContextExecutorService
Linear Supertypes
Known Subclasses
Ordering
- Alphabetic
- By Inheritance
Inherited
- ExecutionContextIdlenessExecutorService
- ExecutionContextExecutorService
- ExecutionContextExecutor
- ExecutionContext
- IdlenessExecutorService
- QueueAwareExecutorService
- NamedExecutor
- QueueAwareExecutor
- ExecutorService
- Executor
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Instance Constructors
- new ExecutionContextIdlenessExecutorService(executorService: ExecutorService, name: String)
Type Members
Abstract Value Members
- abstract def awaitIdlenessOnce(timeout: FiniteDuration): Boolean
- Attributes
- protected[concurrent]
- Definition Classes
- IdlenessExecutorService
- abstract def reportFailure(cause: Throwable): Unit
- Definition Classes
- ExecutionContext
Concrete 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 awaitTermination(l: Long, timeUnit: TimeUnit): Boolean
- Definition Classes
- QueueAwareExecutorService → 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(runnable: Runnable): Unit
- Definition Classes
- QueueAwareExecutorService → Executor
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def getQueueSize: Long
- Definition Classes
- QueueAwareExecutorService
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
- def invokeAll[T](collection: Collection[_ <: Callable[T]], l: Long, timeUnit: TimeUnit): List[Future[T]]
- Definition Classes
- QueueAwareExecutorService → ExecutorService
- def invokeAll[T](collection: Collection[_ <: Callable[T]]): List[Future[T]]
- Definition Classes
- QueueAwareExecutorService → ExecutorService
- def invokeAny[T](collection: Collection[_ <: Callable[T]], l: Long, timeUnit: TimeUnit): T
- Definition Classes
- QueueAwareExecutorService → ExecutorService
- def invokeAny[T](collection: Collection[_ <: Callable[T]]): T
- Definition Classes
- QueueAwareExecutorService → ExecutorService
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def isShutdown(): Boolean
- Definition Classes
- QueueAwareExecutorService → ExecutorService
- def isTerminated(): Boolean
- Definition Classes
- QueueAwareExecutorService → ExecutorService
- val name: String
- Definition Classes
- QueueAwareExecutorService → NamedExecutor
- 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: Long
- Definition Classes
- QueueAwareExecutorService → QueueAwareExecutor
- def shutdown(): Unit
- Definition Classes
- QueueAwareExecutorService → ExecutorService
- def shutdownNow(): List[Runnable]
- Definition Classes
- QueueAwareExecutorService → ExecutorService
- def submit(runnable: Runnable): Future[_]
- Definition Classes
- QueueAwareExecutorService → ExecutorService
- def submit[T](runnable: Runnable, t: T): Future[T]
- Definition Classes
- QueueAwareExecutorService → ExecutorService
- def submit[T](callable: Callable[T]): Future[T]
- Definition Classes
- QueueAwareExecutorService → 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