1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
|
/*
* 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.*
// this function returns a CompletableFuture using Kotlin coroutines
fun supplyTheAnswerAsync(): CompletableFuture<Int> = GlobalScope.future {
println("We might be doing some asynchronous IO here or something else...")
delay(1000) // just do a non-blocking delay
42 // The answer!
}
fun main(args: Array<String>) {
// We can use `supplyTheAnswerAsync` just like any other future-supplier function
val future = supplyTheAnswerAsync()
println("The answer is ${future.get()}")
}
|
