Implementing foreach to work in parallel in Par...

Implementing foreach to work in parallel in ParIterableLike.

Doing a bunch of refactoring around in the collection framework to
ensure a parallel foreach is never called with a side-effecting method.
This still leaves other parts of the standard library and the compiler
unguarded.

No review.

1 files changed, 3 insertions, 1 deletions

diff --git a/src/library/scala/collection/parallel/ParIterableLike.scala b/src/library/scala/collection/parallel/ParIterableLike.scala
index 92c7d5ac97..50a36fa8ed 100644
--- a/src/library/scala/collection/parallel/ParIterableLike.scala
+++ b/src/library/scala/collection/parallel/ParIterableLike.scala
@@ -440,7 +440,9 @@ self: ParIterableLike[T, Repr, Sequential] =>
    *  @tparam U    the result type of the function applied to each element, which is always discarded
    *  @param f     function applied to each element
    */
-  override def foreach[U](f: T => U) = iterator.foreach(f)
+  override def foreach[U](f: T => U) = {
+    executeAndWaitResult(new Foreach(f, parallelIterator))
+  }
 
   override def count(p: T => Boolean): Int = {
     executeAndWaitResult(new Count(p, parallelIterator))