summaryrefslogtreecommitdiff
path: root/test/files/scalacheck/parallel-collections/ParallelArrayCheck.scala
diff options
context:
space:
mode:
authorAleksandar Pokopec <aleksandar.prokopec@epfl.ch>2010-09-01 14:37:53 +0000
committerAleksandar Pokopec <aleksandar.prokopec@epfl.ch>2010-09-01 14:37:53 +0000
commit582753475422403d112bb3b17c19981fb526644a (patch)
treecae1ae3c2e3076d91b72fcfc2a8c0b6c306d8786 /test/files/scalacheck/parallel-collections/ParallelArrayCheck.scala
parentfb950eef1591a0ea5c6b566091bded10032204db (diff)
downloadscala-582753475422403d112bb3b17c19981fb526644a.tar.gz
scala-582753475422403d112bb3b17c19981fb526644a.tar.bz2
scala-582753475422403d112bb3b17c19981fb526644a.zip
Added scalacheck tests for parallel collections.
Review by phaller (not urgent).
Diffstat (limited to 'test/files/scalacheck/parallel-collections/ParallelArrayCheck.scala')
-rw-r--r--test/files/scalacheck/parallel-collections/ParallelArrayCheck.scala67
1 files changed, 67 insertions, 0 deletions
diff --git a/test/files/scalacheck/parallel-collections/ParallelArrayCheck.scala b/test/files/scalacheck/parallel-collections/ParallelArrayCheck.scala
new file mode 100644
index 0000000000..9169890e98
--- /dev/null
+++ b/test/files/scalacheck/parallel-collections/ParallelArrayCheck.scala
@@ -0,0 +1,67 @@
+package scala.collection.parallel
+package mutable
+
+
+
+import org.scalacheck._
+import org.scalacheck.Gen
+import org.scalacheck.Gen._
+import org.scalacheck.Prop._
+import org.scalacheck.Properties
+import org.scalacheck.Arbitrary._
+
+import scala.collection._
+import scala.collection.parallel.ops._
+
+
+abstract class ParallelArrayCheck[T](tp: String) extends ParallelSeqCheck[T]("ParallelArray[" + tp + "]") {
+ ForkJoinTasks.defaultForkJoinPool.setMaximumPoolSize(Runtime.getRuntime.availableProcessors * 2)
+ ForkJoinTasks.defaultForkJoinPool.setParallelism(Runtime.getRuntime.availableProcessors * 2)
+
+ type CollType = ParArray[T]
+
+ def isCheckingViews = false
+
+ def instances(vals: Seq[Gen[T]]): Gen[Seq[T]] = sized { sz =>
+ val a = new mutable.ArrayBuffer[T](sz)
+ val gen = vals(rnd.nextInt(vals.size))
+ for (i <- 0 until sz) a += sample(gen)
+ a
+ }
+
+ def fromSeq(a: Seq[T]) = {
+ val pa = new ParArray[T](a.size)
+ var i = 0
+ for (elem <- a.toList) {
+ pa(i) = elem
+ i += 1
+ }
+ pa
+ }
+
+ property("array mappings must be equal") = forAll(collectionPairs) { case (t, coll) =>
+ val results = for ((f, ind) <- mapFunctions.zipWithIndex)
+ yield ("op index: " + ind) |: t.map(f) == coll.map(f)
+ results.reduceLeft(_ && _)
+ }
+
+}
+
+
+object IntParallelArrayCheck extends ParallelArrayCheck[Int]("Int") with IntSeqOperators with IntValues {
+ override def instances(vals: Seq[Gen[Int]]) = oneOf(super.instances(vals), sized { sz =>
+ (0 until sz).toArray.toSeq
+ }, sized { sz =>
+ (-sz until 0).toArray.toSeq
+ })
+}
+
+
+
+
+
+
+
+
+
+