|
// retoor <retoor@molodetz.nl>
|
|
|
|
import "scheduler" for Scheduler, Future
|
|
import "timer" for Timer
|
|
|
|
var delayedValue = async { |ms, val|
|
|
Timer.sleep(ms)
|
|
return val
|
|
}
|
|
|
|
var f1 = delayedValue.call(10, "first")
|
|
var f2 = delayedValue.call(10, "second")
|
|
var f3 = delayedValue.call(10, "third")
|
|
|
|
System.print(await f1) // expect: first
|
|
System.print(await f2) // expect: second
|
|
System.print(await f3) // expect: third
|
|
|
|
var compute = async { |x| x * x }
|
|
|
|
var futures = []
|
|
for (i in 1..5) {
|
|
futures.add(compute.call(i))
|
|
}
|
|
|
|
var results = []
|
|
for (f in futures) {
|
|
results.add(await f)
|
|
}
|
|
System.print(results) // expect: [1, 4, 9, 16, 25]
|