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
|
discard """
matrix: "--mm:refc"
output: '''true'''
"""
# bug #7638
import threadpool, os
proc timer(d: int): int =
#echo fmt"sleeping {d}"
sleep(d)
#echo fmt"done {d}"
return d
var durations = [1000, 1500, 2000]
var tasks: seq[FlowVarBase] = @[]
var results: seq[int] = @[]
for i in 0 .. durations.high:
tasks.add spawn timer(durations[i])
var index = blockUntilAny(tasks)
while index != -1:
results.add ^cast[FlowVar[int]](tasks[index])
tasks.del(index)
#echo repr results
index = blockUntilAny(tasks)
doAssert results.len == 3
doAssert 1000 in results
doAssert 1500 in results
doAssert 2000 in results
sync()
echo "true"
|