diff options
author | Adriaan Moors <adriaan.moors@typesafe.com> | 2013-11-05 10:26:33 -0800 |
---|---|---|
committer | Adriaan Moors <adriaan.moors@typesafe.com> | 2013-11-05 10:26:33 -0800 |
commit | b33adf47330b510d7d15971fa75aa11c7b9503ad (patch) | |
tree | b7e2546191b867a74eb840e6f9413770c631afd5 /test/files/scalacheck/parallel-collections/ParallelArrayCheck.scala | |
parent | 92ec2cafb3333a710746a1a1bc1351000b2a3372 (diff) | |
parent | 344ac60c3f34cc0a1c6e6aae1479878fe63476eb (diff) | |
download | scala-b33adf47330b510d7d15971fa75aa11c7b9503ad.tar.gz scala-b33adf47330b510d7d15971fa75aa11c7b9503ad.tar.bz2 scala-b33adf47330b510d7d15971fa75aa11c7b9503ad.zip |
Merge pull request #3086 from axel22/topic/pc-execution-context
- parallel collections should use default ExecutionContext
Diffstat (limited to 'test/files/scalacheck/parallel-collections/ParallelArrayCheck.scala')
-rw-r--r-- | test/files/scalacheck/parallel-collections/ParallelArrayCheck.scala | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/test/files/scalacheck/parallel-collections/ParallelArrayCheck.scala b/test/files/scalacheck/parallel-collections/ParallelArrayCheck.scala index 255c04498e..691a3e961e 100644 --- a/test/files/scalacheck/parallel-collections/ParallelArrayCheck.scala +++ b/test/files/scalacheck/parallel-collections/ParallelArrayCheck.scala @@ -24,6 +24,8 @@ abstract class ParallelArrayCheck[T](tp: String) extends ParallelSeqCheck[T]("Pa def hasStrictOrder = true + def tasksupport: TaskSupport + def ofSize(vals: Seq[Gen[T]], sz: Int) = { val a = new mutable.ArrayBuffer[T](sz) val gen = vals(rnd.nextInt(vals.size)) @@ -33,6 +35,7 @@ abstract class ParallelArrayCheck[T](tp: String) extends ParallelSeqCheck[T]("Pa def fromSeq(a: Seq[T]) = { val pa = new ParArray[T](a.size) + pa.tasksupport = tasksupport var i = 0 for (elem <- a.toList) { pa(i) = elem @@ -50,7 +53,7 @@ abstract class ParallelArrayCheck[T](tp: String) extends ParallelSeqCheck[T]("Pa } -object IntParallelArrayCheck extends ParallelArrayCheck[Int]("Int") with IntSeqOperators with IntValues { +class IntParallelArrayCheck(val tasksupport: TaskSupport) 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 => |