Packages

class WrappedTask[R, Tp] extends RecursiveAction with AdaptiveWorkStealingForkJoinTasks.WrappedTask[R, Tp] with AdaptiveWorkStealingForkJoinTasks.WrappedTask[R, Tp]

Source
Tasks.scala
Linear Supertypes
AdaptiveWorkStealingForkJoinTasks.WrappedTask[R, Tp], AdaptiveWorkStealingForkJoinTasks.WrappedTask[R, Tp], AdaptiveWorkStealingForkJoinTasks.WrappedTask[R, Tp], RecursiveAction, ForkJoinTask[Void], java.io.Serializable, Future[Void], AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. WrappedTask
  2. WrappedTask
  3. WrappedTask
  4. WrappedTask
  5. RecursiveAction
  6. ForkJoinTask
  7. Serializable
  8. Future
  9. AnyRef
  10. Any
Implicitly
  1. by CollectionsHaveToParArray
  2. by any2stringadd
  3. by StringFormat
  4. by Ensuring
  5. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new WrappedTask(body: Task[R, Tp])

Value Members

  1. val body: Task[R, Tp]

    the body of this task - what it executes, how it gets split and how results are merged.

    the body of this task - what it executes, how it gets split and how results are merged.

    Definition Classes
    WrappedTaskWrappedTask
  2. def cancel(arg0: Boolean): Boolean
    Definition Classes
    ForkJoinTask → Future
  3. final def compareAndSetForkJoinTaskTag(arg0: Short, arg1: Short): Boolean
    Definition Classes
    ForkJoinTask
  4. def complete(arg0: Void): Unit
    Definition Classes
    ForkJoinTask
  5. def completeExceptionally(arg0: java.lang.Throwable): Unit
    Definition Classes
    ForkJoinTask
  6. def compute(): Unit

    Code that gets called after the task gets started - it may spawn other tasks instead of calling leaf.

    Code that gets called after the task gets started - it may spawn other tasks instead of calling leaf.

    Definition Classes
    WrappedTaskWrappedTask
  7. final def fork(): ForkJoinTask[Void]
    Definition Classes
    ForkJoinTask
  8. final def get(arg0: Long, arg1: TimeUnit): Void
    Definition Classes
    ForkJoinTask → Future
    Annotations
    @throws( ... ) @throws( ... ) @throws( ... )
  9. final def get(): Void
    Definition Classes
    ForkJoinTask → Future
    Annotations
    @throws( ... ) @throws( ... )
  10. final def getException(): java.lang.Throwable
    Definition Classes
    ForkJoinTask
  11. final def getForkJoinTaskTag(): Short
    Definition Classes
    ForkJoinTask
  12. final def getRawResult(): Void
    Definition Classes
    RecursiveAction → ForkJoinTask
  13. def internal(): Unit
    Definition Classes
    WrappedTask
  14. final def invoke(): Void
    Definition Classes
    ForkJoinTask
  15. final def isCancelled(): Boolean
    Definition Classes
    ForkJoinTask → Future
  16. final def isCompletedAbnormally(): Boolean
    Definition Classes
    ForkJoinTask
  17. final def isCompletedNormally(): Boolean
    Definition Classes
    ForkJoinTask
  18. final def isDone(): Boolean
    Definition Classes
    ForkJoinTask → Future
  19. final def join(): Void
    Definition Classes
    ForkJoinTask
  20. val next: AdaptiveWorkStealingForkJoinTasks.WrappedTask[R, Tp]
    Definition Classes
    WrappedTask
    Annotations
    @volatile()
  21. def printChain(): Unit
    Definition Classes
    WrappedTask
  22. final def quietlyComplete(): Unit
    Definition Classes
    ForkJoinTask
  23. final def quietlyInvoke(): Unit
    Definition Classes
    ForkJoinTask
  24. final def quietlyJoin(): Unit
    Definition Classes
    ForkJoinTask
  25. def reinitialize(): Unit
    Definition Classes
    ForkJoinTask
  26. def release(): Unit

    If the task has been cancelled successfully, those syncing on it may automatically be notified, depending on the implementation.

    If the task has been cancelled successfully, those syncing on it may automatically be notified, depending on the implementation. If they aren't, this release method should be called after processing the cancelled task.

    This method may be overridden.

    Definition Classes
    WrappedTask
  27. final def setForkJoinTaskTag(arg0: Short): Short
    Definition Classes
    ForkJoinTask
  28. val shouldWaitFor: Boolean
    Definition Classes
    WrappedTask
    Annotations
    @volatile()
  29. def spawnSubtasks(): AdaptiveWorkStealingForkJoinTasks.WrappedTask[R, Tp]
    Definition Classes
    WrappedTask
  30. def split: scala.Seq[AdaptiveWorkStealingForkJoinTasks.WrappedTask[R, Tp]]
    Definition Classes
    WrappedTaskWrappedTaskWrappedTask
  31. def start(): Unit

    Start task.

    Start task.

    Definition Classes
    WrappedTaskWrappedTask
  32. def sync(): Unit

    Wait for task to finish.

    Wait for task to finish.

    Definition Classes
    WrappedTaskWrappedTask
  33. def toParArray: ParArray[T]
    Implicit
    This member is added by an implicit conversion from WrappedTask[R, Tp] to CollectionsHaveToParArray[WrappedTask[R, Tp], T] performed by method CollectionsHaveToParArray in scala.collection.parallel. This conversion will take place only if an implicit value of type (WrappedTask[R, Tp]) ⇒ GenTraversableOnce[T] is in scope.
    Definition Classes
    CollectionsHaveToParArray
  34. def tryCancel(): Boolean

    Try to cancel the task.

    Try to cancel the task.

    returns

    true if cancellation is successful.

    Definition Classes
    WrappedTaskWrappedTask
  35. def tryUnfork(): Boolean
    Definition Classes
    ForkJoinTask