diff options
author | Aleksandar Pokopec <aleksandar.prokopec@epfl.ch> | 2010-09-23 13:46:26 +0000 |
---|---|---|
committer | Aleksandar Pokopec <aleksandar.prokopec@epfl.ch> | 2010-09-23 13:46:26 +0000 |
commit | a3aa8993d2ed9314206c1fbd2d5b56879f91bb0f (patch) | |
tree | 6ba553f9842c45a40a9131a051ef9dd48739b510 /test/benchmarks/src/scala/collection/parallel/benchmarks/generic/ParallelBenches.scala | |
parent | d7420203456f4369a490310170a2597cb4c32fe6 (diff) | |
download | scala-a3aa8993d2ed9314206c1fbd2d5b56879f91bb0f.tar.gz scala-a3aa8993d2ed9314206c1fbd2d5b56879f91bb0f.tar.bz2 scala-a3aa8993d2ed9314206c1fbd2d5b56879f91bb0f.zip |
Adds a zip for ParIterables + a new Zipped view...
Adds a zip for ParIterables + a new Zipped view for ParSeqView and
ParIterableView + a bench test. No review
Diffstat (limited to 'test/benchmarks/src/scala/collection/parallel/benchmarks/generic/ParallelBenches.scala')
-rw-r--r-- | test/benchmarks/src/scala/collection/parallel/benchmarks/generic/ParallelBenches.scala | 19 |
1 files changed, 19 insertions, 0 deletions
diff --git a/test/benchmarks/src/scala/collection/parallel/benchmarks/generic/ParallelBenches.scala b/test/benchmarks/src/scala/collection/parallel/benchmarks/generic/ParallelBenches.scala index fd4e87ab4c..8516b77191 100644 --- a/test/benchmarks/src/scala/collection/parallel/benchmarks/generic/ParallelBenches.scala +++ b/test/benchmarks/src/scala/collection/parallel/benchmarks/generic/ParallelBenches.scala @@ -200,6 +200,25 @@ self => def companion = IterationA } + object IterationZ extends SeqBenchCompanion { + override def defaultSize = 50000 + def benchName = "iter-z" + def apply(sz: Int, p: Int, w: String) = new IterationZ(sz, p, w) + } + + class IterationZ(val size: Int, val parallelism: Int, val runWhat: String) + extends SeqBench with SeqViewBench { + val zipped = operators.sequence(size) + def comparisonMap = collection.Map("seqview" -> runseqview _) + def runseq = { + val withzip = this.seqcoll.zip(zipped) + withzip.foreach(operators.eachPairFun) + } + def runpar = this.parcoll.zip(zipped).foreach(operators.eachPairFun) + def runseqview = this.seqview.zip(zipped).foreach(operators.eachPairFun) + def companion = IterationZ + } + object Reduce extends SeqBenchCompanion { override def defaultSize = 50000 def benchName = "reduce"; |