akka.dispatch.ForkJoinExecutorConfigurator

AkkaForkJoinPool

final class AkkaForkJoinPool extends ForkJoinPool with LoadMetrics

INTERNAL AKKA USAGE ONLY

Linear Supertypes
LoadMetrics, ForkJoinPool, AbstractExecutorService, ExecutorService, Executor, AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. AkkaForkJoinPool
  2. LoadMetrics
  3. ForkJoinPool
  4. AbstractExecutorService
  5. ExecutorService
  6. Executor
  7. AnyRef
  8. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Instance Constructors

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

Value Members

  1. final def !=(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  2. final def !=(arg0: Any): Boolean

    Definition Classes
    Any

  3. final def ##(): Int

    Definition Classes
    AnyRef → Any

  4. final def ==(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  5. final def ==(arg0: Any): Boolean

    Definition Classes
    Any

  6. final def asInstanceOf[T0]: T0

    Definition Classes
    Any

  7. def atFullThrottle(): Boolean

    Definition Classes
    AkkaForkJoinPool → LoadMetrics

  8. def awaitTermination(arg0: Long, arg1: TimeUnit): Boolean

    Definition Classes
    ForkJoinPool → ExecutorService
    Annotations
    @throws()

  9. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()

  10. def drainTasksTo(arg0: Collection[_ >: ForkJoinTask[_]]): Int

    Attributes
    protected[scala.concurrent.forkjoin]
    Definition Classes
    ForkJoinPool

  11. final def eq(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  12. def equals(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any

  13. def execute(r: Runnable): Unit

    Definition Classes
    AkkaForkJoinPool → ForkJoinPool → Executor

  14. def execute(arg0: ForkJoinTask[_]): Unit

    Definition Classes
    ForkJoinPool

  15. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws()

  16. def getActiveThreadCount(): Int

    Definition Classes
    ForkJoinPool

  17. def getAsyncMode(): Boolean

    Definition Classes
    ForkJoinPool

  18. final def getClass(): Class[_]

    Definition Classes
    AnyRef → Any

  19. def getFactory(): ForkJoinWorkerThreadFactory

    Definition Classes
    ForkJoinPool

  20. def getParallelism(): Int

    Definition Classes
    ForkJoinPool

  21. def getPoolSize(): Int

    Definition Classes
    ForkJoinPool

  22. def getQueuedSubmissionCount(): Int

    Definition Classes
    ForkJoinPool

  23. def getQueuedTaskCount(): Long

    Definition Classes
    ForkJoinPool

  24. def getRunningThreadCount(): Int

    Definition Classes
    ForkJoinPool

  25. def getStealCount(): Long

    Definition Classes
    ForkJoinPool

  26. def getUncaughtExceptionHandler(): UncaughtExceptionHandler

    Definition Classes
    ForkJoinPool

  27. def hasQueuedSubmissions(): Boolean

    Definition Classes
    ForkJoinPool

  28. def hashCode(): Int

    Definition Classes
    AnyRef → Any

  29. def invoke[T](arg0: ForkJoinTask[T]): T

    Definition Classes
    ForkJoinPool

  30. def invokeAll[T](arg0: Collection[_ <: Callable[T]]): List[Future[T]]

    Definition Classes
    ForkJoinPool → AbstractExecutorService → ExecutorService

  31. def invokeAll[T](arg0: Collection[_ <: Callable[T]], arg1: Long, arg2: TimeUnit): List[Future[T]]

    Definition Classes
    AbstractExecutorService → ExecutorService
    Annotations
    @throws()

  32. def invokeAny[T](arg0: Collection[_ <: Callable[T]], arg1: Long, arg2: TimeUnit): T

    Definition Classes
    AbstractExecutorService → ExecutorService
    Annotations
    @throws() @throws() @throws()

  33. def invokeAny[T](arg0: Collection[_ <: Callable[T]]): T

    Definition Classes
    AbstractExecutorService → ExecutorService
    Annotations
    @throws() @throws()

  34. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any

  35. def isQuiescent(): Boolean

    Definition Classes
    ForkJoinPool

  36. def isShutdown(): Boolean

    Definition Classes
    ForkJoinPool → ExecutorService

  37. def isTerminated(): Boolean

    Definition Classes
    ForkJoinPool → ExecutorService

  38. def isTerminating(): Boolean

    Definition Classes
    ForkJoinPool

  39. final def ne(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef

  40. def newTaskFor[T](arg0: Callable[T]): RunnableFuture[T]

    Attributes
    protected[scala.concurrent.forkjoin]
    Definition Classes
    ForkJoinPool → AbstractExecutorService

  41. def newTaskFor[T](arg0: Runnable, arg1: T): RunnableFuture[T]

    Attributes
    protected[scala.concurrent.forkjoin]
    Definition Classes
    ForkJoinPool → AbstractExecutorService

  42. final def notify(): Unit

    Definition Classes
    AnyRef

  43. final def notifyAll(): Unit

    Definition Classes
    AnyRef

  44. def pollSubmission(): ForkJoinTask[_]

    Attributes
    protected[scala.concurrent.forkjoin]
    Definition Classes
    ForkJoinPool

  45. def shutdown(): Unit

    Definition Classes
    ForkJoinPool → ExecutorService

  46. def shutdownNow(): List[Runnable]

    Definition Classes
    ForkJoinPool → ExecutorService

  47. def submit(arg0: Runnable): ForkJoinTask[_]

    Definition Classes
    ForkJoinPool → AbstractExecutorService → ExecutorService

  48. def submit[T](arg0: Runnable, arg1: T): ForkJoinTask[T]

    Definition Classes
    ForkJoinPool → AbstractExecutorService → ExecutorService

  49. def submit[T](arg0: Callable[T]): ForkJoinTask[T]

    Definition Classes
    ForkJoinPool → AbstractExecutorService → ExecutorService

  50. def submit[T](arg0: ForkJoinTask[T]): ForkJoinTask[T]

    Definition Classes
    ForkJoinPool

  51. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef

  52. def toString(): String

    Definition Classes
    ForkJoinPool → AnyRef → Any

  53. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws()

  54. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws()

  55. final def wait(arg0: Long): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws()

Inherited from LoadMetrics

Inherited from ForkJoinPool

Inherited from AbstractExecutorService

Inherited from ExecutorService

Inherited from Executor

Inherited from AnyRef

Inherited from Any

Ungrouped