akka.dispatch.ForkJoinExecutorConfigurator

AkkaForkJoinPool

class AkkaForkJoinPool extends ForkJoinPool with LoadMetrics

INTERNAL AKKA USAGE ONLY

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

Instance Constructors

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

Value Members

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

    Attributes
    final
    Definition Classes
    AnyRef

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

    Attributes
    final
    Definition Classes
    Any

  3. def ## (): Int

    Attributes
    final
    Definition Classes
    AnyRef → Any

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

    Attributes
    final
    Definition Classes
    AnyRef

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

    Attributes
    final
    Definition Classes
    Any

  6. def asInstanceOf [T0] : T0

    Attributes
    final
    Definition Classes
    Any

  7. def atFullThrottle (): Boolean

    Definition Classes
    AkkaForkJoinPool → LoadMetrics

  8. def awaitTermination (timeout: Long, unit: TimeUnit): Boolean

    Definition Classes
    ForkJoinPool → ExecutorService

  9. def clone (): AnyRef

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

  10. def drainTasksTo (c: java.util.Collection[_ >: akka.jsr166y.ForkJoinTask[_]]): Int

    Attributes
    protected[jsr166y]
    Definition Classes
    ForkJoinPool

  11. def eq (arg0: AnyRef): Boolean

    Attributes
    final
    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 (task: akka.jsr166y.ForkJoinTask[_]): Unit

    Definition Classes
    ForkJoinPool

  15. def finalize (): Unit

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

  16. def getActiveThreadCount (): Int

    Definition Classes
    ForkJoinPool

  17. def getAsyncMode (): Boolean

    Definition Classes
    ForkJoinPool

  18. def getClass (): java.lang.Class[_]

    Attributes
    final
    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] (task: ForkJoinTask[T]): T

    Definition Classes
    ForkJoinPool

  30. def invokeAll [T] (tasks: java.util.Collection[_ <: java.util.concurrent.Callable[T]]): List[Future[T]]

    Definition Classes
    ForkJoinPool → AbstractExecutorService → ExecutorService

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

    Definition Classes
    AbstractExecutorService → ExecutorService
    Annotations
    @throws()

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

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

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

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

  34. def isInstanceOf [T0] : Boolean

    Attributes
    final
    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. def ne (arg0: AnyRef): Boolean

    Attributes
    final
    Definition Classes
    AnyRef

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

    Attributes
    protected[jsr166y]
    Definition Classes
    ForkJoinPool → AbstractExecutorService

  41. def newTaskFor [T] (runnable: Runnable, value: T): RunnableFuture[T]

    Attributes
    protected[jsr166y]
    Definition Classes
    ForkJoinPool → AbstractExecutorService

  42. def notify (): Unit

    Attributes
    final
    Definition Classes
    AnyRef

  43. def notifyAll (): Unit

    Attributes
    final
    Definition Classes
    AnyRef

  44. def pollSubmission (): akka.jsr166y.ForkJoinTask[_]

    Attributes
    protected[jsr166y]
    Definition Classes
    ForkJoinPool

  45. def shutdown (): Unit

    Definition Classes
    ForkJoinPool → ExecutorService

  46. def shutdownNow (): List[Runnable]

    Definition Classes
    ForkJoinPool → ExecutorService

  47. def submit (task: Runnable): akka.jsr166y.ForkJoinTask[_]

    Definition Classes
    ForkJoinPool → AbstractExecutorService → ExecutorService

  48. def submit [T] (task: Runnable, result: T): ForkJoinTask[T]

    Definition Classes
    ForkJoinPool → AbstractExecutorService → ExecutorService

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

    Definition Classes
    ForkJoinPool → AbstractExecutorService → ExecutorService

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

    Definition Classes
    ForkJoinPool

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

    Attributes
    final
    Definition Classes
    AnyRef

  52. def toString (): String

    Definition Classes
    ForkJoinPool → AnyRef → Any

  53. def wait (): Unit

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()

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

    Attributes
    final
    Definition Classes
    AnyRef
    Annotations
    @throws()

  55. def wait (arg0: Long): Unit

    Attributes
    final
    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