diff options
| -rw-r--r-- | tests/threads/t5626.nim | 27 |
1 files changed, 0 insertions, 27 deletions
diff --git a/tests/threads/t5626.nim b/tests/threads/t5626.nim deleted file mode 100644 index e7024e5ed..000000000 --- a/tests/threads/t5626.nim +++ /dev/null @@ -1,27 +0,0 @@ -import threadpool - -var ch: Channel[int] -ch.open -var pch = ch.addr - -proc run(f: proc(): int {.gcsafe.}): proc() = - let r = spawn f() - return proc() = await(r) - -var working = false - -proc handler(): int = - while true: - let (h, v) = pch[].tryRecv() - if not h: - discard cas(working.addr, true, false) - break - 1 - -proc send(x: int) = - ch.send(x) - if cas(working.addr, false, true): - discard run(handler) - -for x in 0..1000000: - send(x) \ No newline at end of file |