Scala Library: scala.collection.parallel.ThreadPoolTaskSupport
scala.collection.parallel.ThreadPoolTaskSupport
A task support that uses a thread pool executor to schedule tasks.
- Annotations
- @ deprecated
- Deprecated
- (Since version 2.11.0) Use
ForkJoinTaskSupport
instead.
- (Since version 2.11.0) Use
- Source
- See also
- scala.collection.parallel.TaskSupport for more information.
Type Members
class WrappedTask[R, Tp] extends AdaptiveWorkStealingThreadPoolTasks.WrappedTask[R, Tp] with AdaptiveWorkStealingThreadPoolTasks.WrappedTask[R, Tp]
- Definition Classes
- AdaptiveWorkStealingThreadPoolTasks
Value Members From scala.collection.parallel.AdaptiveWorkStealingThreadPoolTasks ——————————————————————————–
def newWrappedTask[R, Tp](b: Task[R, Tp]): WrappedTask[R, Tp]
- Definition Classes
- AdaptiveWorkStealingThreadPoolTasks → AdaptiveWorkStealingTasks → ThreadPoolTasks
(defined at scala.collection.parallel.AdaptiveWorkStealingThreadPoolTasks)
Instance Constructors From scala.collection.parallel.ThreadPoolTaskSupport
new ThreadPoolTaskSupport(environment: ThreadPoolExecutor = ThreadPoolTasks.defaultThreadPool)
(defined at scala.collection.parallel.ThreadPoolTaskSupport)
Value Members From scala.collection.parallel.ThreadPoolTaskSupport
val environment: ThreadPoolExecutor
The type of the environment is more specific in the implementations.
- Definition Classes
- ThreadPoolTaskSupport → ThreadPoolTasks → Tasks
(defined at scala.collection.parallel.ThreadPoolTaskSupport)
Value Members From scala.collection.parallel.ThreadPoolTasks
def executeAndWaitResult[R, Tp](task: Task[R, Tp]): R
Executes a result task, waits for it to finish, then returns its result. Forwards an exception if some task threw it.
- Definition Classes
- ThreadPoolTasks → Tasks
(defined at scala.collection.parallel.ThreadPoolTasks)
def execute[R, Tp](task: Task[R, Tp]): () ⇒ R
Executes a task and returns a future. Forwards an exception if some task threw it.
- Definition Classes
- ThreadPoolTasks → Tasks
(defined at scala.collection.parallel.ThreadPoolTasks)
def executor: ThreadPoolExecutor
- Definition Classes
- ThreadPoolTasks
(defined at scala.collection.parallel.ThreadPoolTasks)
def queue: LinkedBlockingQueue[Runnable]
- Definition Classes
- ThreadPoolTasks
(defined at scala.collection.parallel.ThreadPoolTasks)
Value Members From Implicit scala.collection.parallel.CollectionsHaveToParArray ——————————————————————————–
def toParArray: ParArray[T]
- Implicit information
- This member is added by an implicit conversion from ThreadPoolTaskSupport to CollectionsHaveToParArray [ThreadPoolTaskSupport, T] performed by method CollectionsHaveToParArray in scala.collection.parallel. This conversion will take place only if an implicit value of type (ThreadPoolTaskSupport) ⇒ GenTraversableOnce [T] is in scope.
- Definition Classes
- CollectionsHaveToParArray (added by implicit convertion: scala.collection.parallel.CollectionsHaveToParArray)
Full Source:
Interested in Scala?
I send out weekly, personalized emails with articles and conference talks.
Subscribe now.