summaryrefslogtreecommitdiff
path: root/src/library/scala/collection/parallel/mutable/ParHashMap.scala
diff options
context:
space:
mode:
Diffstat (limited to 'src/library/scala/collection/parallel/mutable/ParHashMap.scala')
-rw-r--r--src/library/scala/collection/parallel/mutable/ParHashMap.scala24
1 files changed, 0 insertions, 24 deletions
diff --git a/src/library/scala/collection/parallel/mutable/ParHashMap.scala b/src/library/scala/collection/parallel/mutable/ParHashMap.scala
index 42a3302c91..bb3737f18e 100644
--- a/src/library/scala/collection/parallel/mutable/ParHashMap.scala
+++ b/src/library/scala/collection/parallel/mutable/ParHashMap.scala
@@ -6,13 +6,10 @@
** |/ **
\* */
-
package scala
package collection.parallel
package mutable
-
-
import scala.collection.generic._
import scala.collection.mutable.DefaultEntry
import scala.collection.mutable.HashEntry
@@ -20,8 +17,6 @@ import scala.collection.mutable.HashTable
import scala.collection.mutable.UnrolledBuffer
import scala.collection.parallel.Task
-
-
/** A parallel hash map.
*
* `ParHashMap` is a parallel map which internally keeps elements within a hash table.
@@ -145,10 +140,8 @@ self =>
else ("Element " + e.key + " at " + i + " with " + elemHashCode(e.key) + " maps to " + index(elemHashCode(e.key))) :: check(e.next)
check(table(i))
}
-
}
-
/** $factoryInfo
* @define Coll `mutable.ParHashMap`
* @define coll parallel hash map
@@ -163,7 +156,6 @@ object ParHashMap extends ParMapFactory[ParHashMap] {
implicit def canBuildFrom[K, V]: CanCombineFrom[Coll, (K, V), ParHashMap[K, V]] = new CanCombineFromMap[K, V]
}
-
private[mutable] abstract class ParHashMapCombiner[K, V](private val tableLoadFactor: Int)
extends scala.collection.parallel.BucketCombiner[(K, V), ParHashMap[K, V], DefaultEntry[K, V], ParHashMapCombiner[K, V]](ParHashMapCombiner.numblocks)
with scala.collection.mutable.HashTable.HashUtils[K]
@@ -298,10 +290,8 @@ extends scala.collection.parallel.BucketCombiner[(K, V), ParHashMap[K, V], Defau
}
def shouldSplitFurther = howmany > scala.collection.parallel.thresholdFromSize(ParHashMapCombiner.numblocks, combinerTaskSupport.parallelismLevel)
}
-
}
-
private[parallel] object ParHashMapCombiner {
private[mutable] val discriminantbits = 5
private[mutable] val numblocks = 1 << discriminantbits
@@ -310,17 +300,3 @@ private[parallel] object ParHashMapCombiner {
def apply[K, V] = new ParHashMapCombiner[K, V](HashTable.defaultLoadFactor) {} // was: with EnvironmentPassingCombiner[(K, V), ParHashMap[K, V]]
}
-
-
-
-
-
-
-
-
-
-
-
-
-
-