c

com.digitalasset.canton.concurrent

ThreadPoolIdlenessExecutorService

class ThreadPoolIdlenessExecutorService extends ExecutionContextIdlenessExecutorService

Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ThreadPoolIdlenessExecutorService
  2. ExecutionContextIdlenessExecutorService
  3. ExecutionContextExecutorService
  4. ExecutionContextExecutor
  5. ExecutionContext
  6. IdlenessExecutorService
  7. QueueAwareExecutorService
  8. NamedExecutor
  9. QueueAwareExecutor
  10. ExecutorService
  11. Executor
  12. AnyRef
  13. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new ThreadPoolIdlenessExecutorService(pool: ThreadPoolExecutor, reporter: (Throwable) => Unit, name: String)

Type Members

  1. class TrackingCallable[T] extends Callable[T]
    Definition Classes
    QueueAwareExecutorService
  2. class TrackingRunnable extends Runnable
    Definition Classes
    QueueAwareExecutorService

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 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()
  6. def awaitIdlenessOnce(timeout: FiniteDuration): Boolean
    Attributes
    protected[concurrent]
    Definition Classes
    ThreadPoolIdlenessExecutorServiceIdlenessExecutorService
  7. def awaitTermination(l: Long, timeUnit: TimeUnit): Boolean
    Definition Classes
    QueueAwareExecutorService → ExecutorService
  8. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @native() @IntrinsicCandidate()
  9. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  10. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  11. def execute(runnable: Runnable): Unit
    Definition Classes
    QueueAwareExecutorService → Executor
  12. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @IntrinsicCandidate()
  13. def getQueueSize: Long
    Definition Classes
    QueueAwareExecutorService
  14. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @IntrinsicCandidate()
  15. def invokeAll[T](collection: Collection[_ <: Callable[T]], l: Long, timeUnit: TimeUnit): List[Future[T]]
    Definition Classes
    QueueAwareExecutorService → ExecutorService
  16. def invokeAll[T](collection: Collection[_ <: Callable[T]]): List[Future[T]]
    Definition Classes
    QueueAwareExecutorService → ExecutorService
  17. def invokeAny[T](collection: Collection[_ <: Callable[T]], l: Long, timeUnit: TimeUnit): T
    Definition Classes
    QueueAwareExecutorService → ExecutorService
  18. def invokeAny[T](collection: Collection[_ <: Callable[T]]): T
    Definition Classes
    QueueAwareExecutorService → ExecutorService
  19. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  20. def isShutdown(): Boolean
    Definition Classes
    QueueAwareExecutorService → ExecutorService
  21. def isTerminated(): Boolean
    Definition Classes
    QueueAwareExecutorService → ExecutorService
  22. val name: String
    Definition Classes
    ThreadPoolIdlenessExecutorService → QueueAwareExecutorService → NamedExecutor
  23. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  24. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @IntrinsicCandidate()
  25. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @IntrinsicCandidate()
  26. def queueSize: Long
    Definition Classes
    QueueAwareExecutorService → QueueAwareExecutor
  27. def reportFailure(cause: Throwable): Unit
    Definition Classes
    ThreadPoolIdlenessExecutorService → ExecutionContext
  28. def shutdown(): Unit
    Definition Classes
    QueueAwareExecutorService → ExecutorService
  29. def shutdownNow(): List[Runnable]
    Definition Classes
    QueueAwareExecutorService → ExecutorService
  30. def submit(runnable: Runnable): Future[_]
    Definition Classes
    QueueAwareExecutorService → ExecutorService
  31. def submit[T](runnable: Runnable, t: T): Future[T]
    Definition Classes
    QueueAwareExecutorService → ExecutorService
  32. def submit[T](callable: Callable[T]): Future[T]
    Definition Classes
    QueueAwareExecutorService → ExecutorService
  33. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  34. def toString(): String
    Definition Classes
    AnyRef → Any
  35. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  36. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  37. 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
    Deprecated
  2. def prepare(): ExecutionContext
    Definition Classes
    ExecutionContext
    Annotations
    @deprecated
    Deprecated

    (Since version 2.12.0) preparation of ExecutionContexts will be removed

Inherited from ExecutionContext

Inherited from NamedExecutor

Inherited from QueueAwareExecutor

Inherited from ExecutorService

Inherited from Executor

Inherited from AnyRef

Inherited from Any

Ungrouped