Packages

class WrappedTask[R, Tp] extends AdaptiveWorkStealingThreadPoolTasks.WrappedTask[R, Tp] with AdaptiveWorkStealingThreadPoolTasks.WrappedTask[R, Tp]

Source
Tasks.scala
Linear Supertypes
AdaptiveWorkStealingThreadPoolTasks.WrappedTask[R, Tp], AdaptiveWorkStealingThreadPoolTasks.WrappedTask[R, Tp], AdaptiveWorkStealingThreadPoolTasks.WrappedTask[R, Tp], Runnable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. WrappedTask
  2. WrappedTask
  3. WrappedTask
  4. WrappedTask
  5. Runnable
  6. AnyRef
  7. 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. val completed: Boolean
    Definition Classes
    WrappedTask
    Annotations
    @volatile()
  3. 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
  4. def internal(): Unit
    Definition Classes
    WrappedTask
  5. val next: AdaptiveWorkStealingThreadPoolTasks.WrappedTask[R, Tp]
    Definition Classes
    WrappedTask
    Annotations
    @volatile()
  6. val owned: Boolean
    Definition Classes
    WrappedTask
    Annotations
    @volatile()
  7. def printChain(): Unit
    Definition Classes
    WrappedTask
  8. 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
    WrappedTaskWrappedTask
  9. def run(): Unit
    Definition Classes
    WrappedTask → Runnable
  10. val shouldWaitFor: Boolean
    Definition Classes
    WrappedTask
    Annotations
    @volatile()
  11. def spawnSubtasks(): AdaptiveWorkStealingThreadPoolTasks.WrappedTask[R, Tp]
    Definition Classes
    WrappedTask
  12. def split: scala.Seq[AdaptiveWorkStealingThreadPoolTasks.WrappedTask[R, Tp]]
    Definition Classes
    WrappedTaskWrappedTaskWrappedTask
  13. def start(): Unit

    Start task.

    Start task.

    Definition Classes
    WrappedTaskWrappedTask
  14. def sync(): Unit

    Wait for task to finish.

    Wait for task to finish.

    Definition Classes
    WrappedTaskWrappedTask
  15. 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
  16. def tryCancel(): Boolean

    Try to cancel the task.

    Try to cancel the task.

    returns

    true if cancellation is successful.

    Definition Classes
    WrappedTaskWrappedTask