diff options
author | Aleksandar Pokopec <aleksandar.prokopec@epfl.ch> | 2010-07-26 16:31:47 +0000 |
---|---|---|
committer | Aleksandar Pokopec <aleksandar.prokopec@epfl.ch> | 2010-07-26 16:31:47 +0000 |
commit | c6cc8c72820a5d540b9bfa4a8dc52eb0923936f1 (patch) | |
tree | 965972aad5bbd243e9438ea9bbe73a1d5766135c /test/benchmarks/src/scala/collection/parallel/benchmarks/hashtries/ParallelHashTries.scala | |
parent | 0ce0ad51284ba129a7553ea2ec98d1be45660706 (diff) | |
download | scala-c6cc8c72820a5d540b9bfa4a8dc52eb0923936f1.tar.gz scala-c6cc8c72820a5d540b9bfa4a8dc52eb0923936f1.tar.bz2 scala-c6cc8c72820a5d540b9bfa4a8dc52eb0923936f1.zip |
Refactored benchmarks.
Diffstat (limited to 'test/benchmarks/src/scala/collection/parallel/benchmarks/hashtries/ParallelHashTries.scala')
-rw-r--r-- | test/benchmarks/src/scala/collection/parallel/benchmarks/hashtries/ParallelHashTries.scala | 18 |
1 files changed, 9 insertions, 9 deletions
diff --git a/test/benchmarks/src/scala/collection/parallel/benchmarks/hashtries/ParallelHashTries.scala b/test/benchmarks/src/scala/collection/parallel/benchmarks/hashtries/ParallelHashTries.scala index c617f69161..bec8ba6650 100644 --- a/test/benchmarks/src/scala/collection/parallel/benchmarks/hashtries/ParallelHashTries.scala +++ b/test/benchmarks/src/scala/collection/parallel/benchmarks/hashtries/ParallelHashTries.scala @@ -3,19 +3,19 @@ package scala.collection.parallel.benchmarks.hashtries -import scala.collection.parallel.benchmarks.generic.StandardParallelIterableBench +import scala.collection.parallel.benchmarks.generic.StandardParIterableBench import scala.collection.parallel.benchmarks.generic.NotBenchmark import scala.collection.parallel.benchmarks.generic.Dummy import scala.collection.parallel.benchmarks.generic.Operators -import scala.collection.parallel.immutable.ParallelHashTrie +import scala.collection.parallel.immutable.ParHashTrie -trait ParallelHashTrieBenches[K, V] extends StandardParallelIterableBench[(K, V), ParallelHashTrie[K, V]] { +trait ParHashTrieBenches[K, V] extends StandardParIterableBench[(K, V), ParHashTrie[K, V]] { - def nameOfCollection = "ParallelHashTrie" + def nameOfCollection = "ParHashTrie" def comparisonMap = collection.Map() val forkJoinPool = new scala.concurrent.forkjoin.ForkJoinPool @@ -26,7 +26,7 @@ trait ParallelHashTrieBenches[K, V] extends StandardParallelIterableBench[(K, V) } class Map2(val size: Int, val parallelism: Int, val runWhat: String) - extends IterableBench with StandardParallelIterableBench[(K, V), ParallelHashTrie[K, V]] { + extends IterableBench with StandardParIterableBench[(K, V), ParHashTrie[K, V]] { var result: Int = 0 def comparisonMap = collection.Map() def runseq = { @@ -35,13 +35,13 @@ trait ParallelHashTrieBenches[K, V] extends StandardParallelIterableBench[(K, V) } def runpar = { result = this.parcoll.map(operators.mapper2).size - //println(collection.parallel.immutable.ParallelHashTrie.totalcombines) + //println(collection.parallel.immutable.ParHashTrie.totalcombines) //System.exit(1) } def companion = Map2 override def repetitionsPerRun = 50 override def printResults { - println("Total combines: " + collection.parallel.immutable.ParallelHashTrie.totalcombines) + println("Total combines: " + collection.parallel.immutable.ParHashTrie.totalcombines) println("Size of last result: " + result) } } @@ -52,7 +52,7 @@ trait ParallelHashTrieBenches[K, V] extends StandardParallelIterableBench[(K, V) -object RefParallelHashTrieBenches extends ParallelHashTrieBenches[Dummy, Dummy] with NotBenchmark { +object RefParHashTrieBenches extends ParHashTrieBenches[Dummy, Dummy] with NotBenchmark { type DPair = (Dummy, Dummy) @@ -111,7 +111,7 @@ object RefParallelHashTrieBenches extends ParallelHashTrieBenches[Dummy, Dummy] } def createParallel(sz: Int, p: Int) = { - var pht = new ParallelHashTrie[Dummy, Dummy] + var pht = new ParHashTrie[Dummy, Dummy] for (i <- 0 until sz) pht += ((new Dummy(i), new Dummy(i))) forkJoinPool.setParallelism(p) pht.environment = forkJoinPool |