mirror of
https://github.com/KevinMidboe/linguist.git
synced 2025-10-29 17:50:22 +00:00
85 lines
2.2 KiB
Plaintext
Executable File
85 lines
2.2 KiB
Plaintext
Executable File
# Copyright 2012-2014 Institut National des Sciences Appliquées de Lyon (INSA-Lyon)
|
|
#
|
|
# Licensed under the Apache License, Version 2.0 (the "License");
|
|
# you may not use this file except in compliance with the License.
|
|
# You may obtain a copy of the License at
|
|
#
|
|
# http://www.apache.org/licenses/LICENSE-2.0
|
|
#
|
|
# Unless required by applicable law or agreed to in writing, software
|
|
# distributed under the License is distributed on an "AS IS" BASIS,
|
|
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
# See the License for the specific language governing permissions and
|
|
# limitations under the License.
|
|
|
|
module samples.AsyncHelpers
|
|
|
|
import gololang.Async
|
|
import java.util.concurrent.TimeUnit
|
|
import java.util.concurrent.Executors
|
|
|
|
local function fib = |n| {
|
|
if n <= 1 {
|
|
return n
|
|
} else {
|
|
return fib(n - 1) + fib(n - 2)
|
|
}
|
|
}
|
|
|
|
function main = |args| {
|
|
|
|
let executor = newCachedThreadPool()
|
|
println("Let's do some useless asynchronous operations...")
|
|
|
|
var f = executor: enqueue({
|
|
Thread.sleep(1000_L)
|
|
return 666
|
|
})
|
|
f:
|
|
onSet(|v| -> println(">>> #slow -> " + v)):
|
|
onFail(|e| -> println(">>> #fail -> " + e))
|
|
f:
|
|
cancel(true)
|
|
|
|
f = executor: enqueue({
|
|
Thread.sleep(1000_L)
|
|
return 666
|
|
})
|
|
f:
|
|
onSet(|v| -> println(">>> #ok -> " + v)):
|
|
onFail(|e| -> println(">>> #wtf? -> " + e))
|
|
|
|
let fib_10 = promise()
|
|
let fib_20 = promise()
|
|
let fib_30 = promise()
|
|
let fib_40 = promise()
|
|
|
|
let futures = [
|
|
fib_10: future(), fib_20: future(),
|
|
fib_30: future(), fib_40: future()
|
|
]
|
|
|
|
executor: submit(-> fib_10: set(fib(10)))
|
|
executor: submit(-> fib_20: set(fib(20)))
|
|
executor: submit(-> fib_30: set(fib(30)))
|
|
executor: submit(-> fib_40: set(fib(40)))
|
|
|
|
all(futures): onSet(|results| -> println(">>> Fibs: " + results))
|
|
|
|
let truth = promise()
|
|
truth:
|
|
future():
|
|
map(|v| -> "truth=" + v):
|
|
onSet(|v| -> executor: submit(-> println(">>> (another thread) " + v))):
|
|
onSet(|v| -> println(">>> (same thread) " + v))
|
|
executor: submit({
|
|
Thread.sleep(500_L)
|
|
truth: set(42)
|
|
})
|
|
|
|
Thread.sleep(1000_L)
|
|
executor: shutdown()
|
|
executor: awaitTermination(2_L, SECONDS())
|
|
println("Bye!")
|
|
}
|