From af011572ee74162202b2a66a98bf5e480b5b435b Mon Sep 17 00:00:00 2001 From: Philipp Haller Date: Thu, 24 Mar 2011 14:19:35 +0000 Subject: Added implicit TaskRunner parameters to scala.c... Added implicit TaskRunner parameters to scala.concurrent.ops.{par, replicate}. Review by prokopec. --- src/library/scala/concurrent/ops.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'src/library') diff --git a/src/library/scala/concurrent/ops.scala b/src/library/scala/concurrent/ops.scala index 06f745e26b..5542472ce1 100644 --- a/src/library/scala/concurrent/ops.scala +++ b/src/library/scala/concurrent/ops.scala @@ -57,7 +57,7 @@ object ops * * @return a pair holding the evaluation results */ - def par[A, B](xp: => A, yp: => B): (A, B) = { + def par[A, B](xp: => A, yp: => B)(implicit runner: TaskRunner = defaultRunner): (A, B) = { val y = new SyncVar[Either[Throwable, B]] spawn { y set tryCatch(yp) } (xp, getOrThrow(y.get)) @@ -69,7 +69,7 @@ object ops * @param p ... */ @deprecated("use `collection.parallel.ParIterable.foreach' instead") - def replicate(start: Int, end: Int)(p: Int => Unit) { + def replicate(start: Int, end: Int)(p: Int => Unit)(implicit runner: TaskRunner = defaultRunner) { if (start == end) () else if (start + 1 == end) -- cgit v1.2.3