blob: da96362413d3ee27a0a3b0839a5cf712b1d6fef3 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
|
package scala.collection.immutable
import org.junit.Test
import org.junit.runner.RunWith
import org.junit.runners.JUnit4
@RunWith(classOf[JUnit4])
class ParallelConsistencyTest {
private val theSeq = Seq(1,2,3)
// This collection will throw an exception if you do anything but call .length or .seq
private val mustCallSeq: collection.GenSeq[Int] = new collection.parallel.ParSeq[Int] {
def length = 3
// This method is surely sequential & safe -- want all access to go through here
def seq = theSeq
def notSeq = throw new Exception("Access to parallel collection not via .seq")
// These methods could possibly be used dangerously explicitly or internally
// (apply could also be used safely; if it is, do test with mustCallSeq)
def apply(i: Int) = notSeq
def splitter = notSeq
}
// Test Vector ++ with a small parallel collection concatenation (SI-9072).
@Test
def testPlusPlus(): Unit = {
assert((Vector.empty ++ mustCallSeq) == theSeq, "Vector ++ unsafe with parallel vectors")
}
// SI-9126, 1 of 2
@Test
def testTranspose(): Unit = {
assert(List(mustCallSeq).transpose.flatten == theSeq, "Transposing inner parallel collection unsafe")
}
// SI-9126, 2 of 2
@Test
def testList_flatMap(): Unit = {
assert(List(1).flatMap(_ => mustCallSeq) == theSeq, "List#flatMap on inner parallel collection unsafe")
}
}
|
