Packages

final class AkkaForkJoinPool extends ForkJoinPool with LoadMetrics

INTERNAL AKKA USAGE ONLY

Source
ForkJoinExecutorConfigurator.scala
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. AkkaForkJoinPool
  2. LoadMetrics
  3. ForkJoinPool
  4. AbstractExecutorService
  5. ExecutorService
  6. Executor
  7. AnyRef
  8. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new AkkaForkJoinPool(parallelism: Int, threadFactory: ForkJoinWorkerThreadFactory, unhandledExceptionHandler: UncaughtExceptionHandler)
  2. new AkkaForkJoinPool(parallelism: Int, threadFactory: ForkJoinWorkerThreadFactory, unhandledExceptionHandler: UncaughtExceptionHandler, asyncMode: Boolean)

Value Members

  1. def atFullThrottle(): Boolean
    Definition Classes
    AkkaForkJoinPool → LoadMetrics
  2. def awaitQuiescence(arg0: Long, arg1: TimeUnit): Boolean
    Definition Classes
    ForkJoinPool
  3. def awaitTermination(arg0: Long, arg1: TimeUnit): Boolean
    Definition Classes
    ForkJoinPool → ExecutorService
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  4. def execute(r: Runnable): Unit
    Definition Classes
    AkkaForkJoinPool → ForkJoinPool → Executor
  5. def execute(arg0: ForkJoinTask[_ <: AnyRef]): Unit
    Definition Classes
    ForkJoinPool
  6. def getActiveThreadCount(): Int
    Definition Classes
    ForkJoinPool
  7. def getAsyncMode(): Boolean
    Definition Classes
    ForkJoinPool
  8. def getFactory(): ForkJoinWorkerThreadFactory
    Definition Classes
    ForkJoinPool
  9. def getParallelism(): Int
    Definition Classes
    ForkJoinPool
  10. def getPoolSize(): Int
    Definition Classes
    ForkJoinPool
  11. def getQueuedSubmissionCount(): Int
    Definition Classes
    ForkJoinPool
  12. def getQueuedTaskCount(): Long
    Definition Classes
    ForkJoinPool
  13. def getRunningThreadCount(): Int
    Definition Classes
    ForkJoinPool
  14. def getStealCount(): Long
    Definition Classes
    ForkJoinPool
  15. def getUncaughtExceptionHandler(): UncaughtExceptionHandler
    Definition Classes
    ForkJoinPool
  16. def hasQueuedSubmissions(): Boolean
    Definition Classes
    ForkJoinPool
  17. def invoke[T <: AnyRef](arg0: ForkJoinTask[T]): T
    Definition Classes
    ForkJoinPool
  18. def invokeAll[T <: AnyRef](arg0: Collection[_ <: Callable[T]]): List[Future[T]]
    Definition Classes
    ForkJoinPool → AbstractExecutorService → ExecutorService
  19. def invokeAll[T <: AnyRef](arg0: Collection[_ <: Callable[T]], arg1: Long, arg2: TimeUnit): List[Future[T]]
    Definition Classes
    AbstractExecutorService → ExecutorService
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  20. def invokeAny[T <: AnyRef](arg0: Collection[_ <: Callable[T]], arg1: Long, arg2: TimeUnit): T
    Definition Classes
    AbstractExecutorService → ExecutorService
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @throws(classOf[java.util.concurrent.ExecutionException]) @throws(classOf[java.util.concurrent.TimeoutException])
  21. def invokeAny[T <: AnyRef](arg0: Collection[_ <: Callable[T]]): T
    Definition Classes
    AbstractExecutorService → ExecutorService
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @throws(classOf[java.util.concurrent.ExecutionException])
  22. def isQuiescent(): Boolean
    Definition Classes
    ForkJoinPool
  23. def isShutdown(): Boolean
    Definition Classes
    ForkJoinPool → ExecutorService
  24. def isTerminated(): Boolean
    Definition Classes
    ForkJoinPool → ExecutorService
  25. def isTerminating(): Boolean
    Definition Classes
    ForkJoinPool
  26. def shutdown(): Unit
    Definition Classes
    ForkJoinPool → ExecutorService
  27. def shutdownNow(): List[Runnable]
    Definition Classes
    ForkJoinPool → ExecutorService
  28. def submit(arg0: Runnable): ForkJoinTask[_ <: AnyRef]
    Definition Classes
    ForkJoinPool → AbstractExecutorService → ExecutorService
  29. def submit[T <: AnyRef](arg0: Runnable, arg1: T): ForkJoinTask[T]
    Definition Classes
    ForkJoinPool → AbstractExecutorService → ExecutorService
  30. def submit[T <: AnyRef](arg0: Callable[T]): ForkJoinTask[T]
    Definition Classes
    ForkJoinPool → AbstractExecutorService → ExecutorService
  31. def submit[T <: AnyRef](arg0: ForkJoinTask[T]): ForkJoinTask[T]
    Definition Classes
    ForkJoinPool
  32. def toString(): String
    Definition Classes
    ForkJoinPool → AnyRef → Any