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
|
/*
* Copyright 2016-2018 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
*/
package kotlinx.coroutines.examples
import kotlinx.coroutines.*
import kotlinx.coroutines.future.*
import java.util.concurrent.CancellationException
fun main(args: Array<String>) {
val job = Job()
log("Starting futures f && g")
val f = GlobalScope.future(job) {
log("Started f")
delay(500)
log("f should not execute this line")
}
val g = GlobalScope.future(job) {
log("Started g")
try {
delay(500)
} finally {
log("g is executing finally!")
}
log("g should not execute this line")
}
log("Started futures f && g... will not wait -- cancel them!!!")
job.cancel(CancellationException("I don't want it"))
check(f.isCancelled)
check(g.isCancelled)
log("f result = ${Try<Unit> { f.get() }}")
log("g result = ${Try<Unit> { g.get() }}")
Thread.sleep(1000L)
log("Nothing executed!")
}
|
