diff options
author | Aleksandar Pokopec <aleksandar.prokopec@epfl.ch> | 2010-09-13 16:07:33 +0000 |
---|---|---|
committer | Aleksandar Pokopec <aleksandar.prokopec@epfl.ch> | 2010-09-13 16:07:33 +0000 |
commit | cfb6168dc5eef906b2552c7b40765db1d6720652 (patch) | |
tree | 4ba1ffd338f7dac34a7c08ac29a03e005b2ca34f /test/benchmarks | |
parent | f7a6c8823b39c622a1f96f9aaafb828427d4edda (diff) | |
download | scala-cfb6168dc5eef906b2552c7b40765db1d6720652.tar.gz scala-cfb6168dc5eef906b2552c7b40765db1d6720652.tar.bz2 scala-cfb6168dc5eef906b2552c7b40765db1d6720652.zip |
Improving parallel scan. No review
Diffstat (limited to 'test/benchmarks')
-rw-r--r-- | test/benchmarks/src/scala/collection/parallel/benchmarks/parallel_array/ScanLight.scala | 14 |
1 files changed, 10 insertions, 4 deletions
diff --git a/test/benchmarks/src/scala/collection/parallel/benchmarks/parallel_array/ScanLight.scala b/test/benchmarks/src/scala/collection/parallel/benchmarks/parallel_array/ScanLight.scala index b18b98a208..02a52ac207 100644 --- a/test/benchmarks/src/scala/collection/parallel/benchmarks/parallel_array/ScanLight.scala +++ b/test/benchmarks/src/scala/collection/parallel/benchmarks/parallel_array/ScanLight.scala @@ -8,10 +8,13 @@ import scala.collection.parallel.mutable.ParArray object ScanLight extends Companion { def benchName = "scan-light"; def apply(sz: Int, parallelism: Int, what: String) = new ScanLight(sz, parallelism, what) - override def comparisons = List() + override def comparisons = List("jsr") override def defaultSize = 40000 val op = (a: Cont, b: Cont) => { + operation(a, b) + } + def operation(a: Cont, b: Cont) = { val m = if (a.in < 0) 1 else 0 new Cont(a.in + b.in + m * (0 until 10).reduceLeft(_ + _)) } @@ -21,12 +24,15 @@ object ScanLight extends Companion { class ScanLight(sz: Int, p: Int, what: String) extends Resettable[Cont](sz, p, what, new Cont(_), new Array[Any](_), classOf[Cont]) { def companion = ScanLight - override def repetitionsPerRun = 10 - override val runs = 10 + override def repetitionsPerRun = 50 + override val runs = 12 def runpar = pa.scan(new Cont(0))(ScanLight.op) def runseq = sequentialScan(new Cont(0), ScanLight.op, sz) - override def comparisonMap = collection.Map() + def runjsr = jsrarr.cumulate(new extra166y.Ops.Reducer[Cont] { + def op(a: Cont, b: Cont) = ScanLight.operation(a, b) + }, new Cont(0)) + override def comparisonMap = collection.Map("jsr" -> runjsr _) } |