dstarcev
03/23/2017, 1:05 PMTask.WhenAll()
in kotlin?deviant
03/23/2017, 2:49 PMkrotki
03/23/2017, 6:25 PMimport kotlinx.coroutines.experimental.delay
import kotlinx.coroutines.experimental.future.future
import java.util.concurrent.CompletableFuture
import kotlin.system.measureTimeMillis
fun main(args: Array<String>) {
val time1 = measureTimeMillis {
listOf(1, 2, 3)
.map { i -> future { delay(i * 1000L); 42 } }
.map { it.get() }
}
println("Completed in $time1 ms")
val time2 = measureTimeMillis {
val tasks = listOf(1, 2, 3)
.map { i -> future { delay(i * 1000L); 42 } }
CompletableFuture.allOf(*tasks.toTypedArray()).get()
}
println("Completed in $time2 ms")
}