summaryrefslogtreecommitdiff
path: root/test/benchmarks/src/scala/collection/parallel/benchmarks/generic/ParallelBenches.scala
diff options
context:
space:
mode:
authorAleksandar Pokopec <aleksandar.prokopec@epfl.ch>2010-09-23 13:46:26 +0000
committerAleksandar Pokopec <aleksandar.prokopec@epfl.ch>2010-09-23 13:46:26 +0000
commita3aa8993d2ed9314206c1fbd2d5b56879f91bb0f (patch)
tree6ba553f9842c45a40a9131a051ef9dd48739b510 /test/benchmarks/src/scala/collection/parallel/benchmarks/generic/ParallelBenches.scala
parentd7420203456f4369a490310170a2597cb4c32fe6 (diff)
downloadscala-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.scala19
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";