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, 0 deletions

diff --git a/src/library/scala/collection/parallel/Tasks.scala b/src/library/scala/collection/parallel/Tasks.scala
index 921223217d..f855dede19 100644
--- a/src/library/scala/collection/parallel/Tasks.scala
+++ b/src/library/scala/collection/parallel/Tasks.scala
@@ -329,6 +329,8 @@ object ThreadPoolTasks {
 
   val numCores = Runtime.getRuntime.availableProcessors
 
+  val tcount = new atomic.AtomicLong(0L)
+
   val defaultThreadPool = new ThreadPoolExecutor(
     numCores,
     Int.MaxValue,
@@ -337,6 +339,7 @@ object ThreadPoolTasks {
     new ThreadFactory {
       def newThread(r: Runnable) = {
         val t = new Thread(r)
+        t.setName("pc-thread-" + tcount.incrementAndGet)
         t.setDaemon(true)
         t
       }