logos-storage/apatheia
1
0
Fork 0
mirror of https://github.com/logos-storage/apatheia.git synced 2026-01-09 08:23:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

simple signal

Browse Source
This commit is contained in:
Jaremy Creechley 2024-02-08 22:23:40 -07:00
parent e2fb9582d2
commit b48d21966d
No known key found for this signature in database
GPG Key ID: 4E66FB67B21D3300
1 changed files with 11 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
tests/tasyncsEx1.nim
View File

@ -1,3 +1,4 @@
import std/os
import chronos
import chronos/threadsync
@ -13,8 +14,12 @@ type
doneSig: ThreadSignalPtr
value: float
proc addNums(a, b: float, ret: ptr float) =
ret[] = a + b
proc addNums(a, b: float, ret: ptr ThreadArg) =
ret.value = a + b
os.sleep(1_000)
let res = ret.doneSig.fireSync().get()
if not res:
echo "ERROR FIRING!"
suite "async tests":
@ -25,8 +30,10 @@ suite "async tests":
args.startSig = ThreadSignalPtr.new().get()
args.doneSig = ThreadSignalPtr.new().get()
tp.spawn addNums(1, 2, addr args.value)
await sleepAsync(100.milliseconds)
tp.spawn addNums(1, 2, addr args)
# await sleepAsync(100.milliseconds)
await wait(args.doneSig).wait(1500.milliseconds)
echo "\nRES: ", args.value
check true