logos-storage/apatheia
1
0
Fork 0
mirror of https://github.com/logos-storage/apatheia.git synced 2026-01-05 14:33:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

setting up wrappers

Browse Source
This commit is contained in:
Jaremy Creechley 2024-02-13 22:46:35 -07:00
parent e390d915fa
commit 3fd3bb2f3d
No known key found for this signature in database
GPG Key ID: 4E66FB67B21D3300
2 changed files with 9 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
tests/tjobs.nim
View File

@ -32,7 +32,7 @@ suite "async tests":
var jobs = newJobQueue[float](taskpool = tp) var jobs = newJobQueue[float](taskpool = tp)
echo "\nstart" echo "\nstart"
let res = await jobs.submit(addNums2(1.0, 2.0,)) let res = await jobs.submit(addNums(1.0, 2.0,))
# await sleepAsync(100.milliseconds) # await sleepAsync(100.milliseconds)
echo "result: ", res.repr echo "result: ", res.repr

20
tests/ttasks.nim
View File

@ -17,15 +17,11 @@ proc addNums(a, b: float): float {.asyncTask.} =
echo "adding: ", a, " + ", b echo "adding: ", a, " + ", b
return a + b return a + b
# proc addNums(jobResult: JobResult[float], a, b: float) = suite "async tests":
# let res = addNumsRaw(a, b) var tp = Taskpool.new(num_threads = 2) # Default to the number of hardware threads.
# discard jobResult.queue.send((jobResult.id, res,)) asyncTest "test":
var jobs = newJobQueue[float](taskpool = tp)
# suite "async tests": echo "\nstart"
# var tp = Taskpool.new(num_threads = 2) # Default to the number of hardware threads. let res = await jobs.submit(addNums(1.0, 2.0,))
# asyncTest "test": echo "result: ", res.repr
# var jobs = newJobQueue[float](taskpool = tp) check true
# echo "\nstart"
# let res = await jobs.submit(addNums(1.0, 2.0,))
# echo "result: ", res.repr
# check true