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
|
/*
* Copyright 2016-2018 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
*/
package kotlinx.coroutines
import kotlin.test.*
class CoroutinesJvmTest : TestBase() {
@Test
fun testNotCancellableCodeWithExceptionCancelled() = runTest(expected = {e -> e is TestException}) {
expect(1)
// CoroutineStart.ATOMIC makes sure it will not get cancelled for it starts executing
val job = launch(start = CoroutineStart.ATOMIC) {
Thread.sleep(100) // cannot be cancelled
throwTestException() // will throw
expectUnreached()
}
expect(2)
job.cancel()
finish(3)
}
@Test
fun testCancelManyCompletedAttachedChildren() = runTest {
val parent = launch { /* do nothing */ }
val n = 10_000 * stressTestMultiplier
repeat(n) {
// create a child that already completed
val child = launch(start = CoroutineStart.UNDISPATCHED) { /* do nothing */ }
// attach it manually via internal API
@Suppress("DEPRECATION_ERROR")
parent.attachChild(child as ChildJob)
}
parent.cancelAndJoin() // cancel parent, make sure no stack overflow
}
private fun throwTestException(): Unit = throw TestException()
}
|
