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

setup jobs

Browse Source
This commit is contained in:
Jaremy Creechley 2024-02-09 23:04:13 -07:00
parent 98075da2b2
commit 33a837cf65
No known key found for this signature in database
GPG Key ID: 4E66FB67B21D3300
2 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/apatheia/jobs.nim
View File

@ -47,7 +47,7 @@ macro submitMacro*(tp: untyped, jobs: untyped, exp: untyped): untyped =
echo "submit: ", fncall.treeRepr
result = quote do:
let `queueName` = jobs.queue
let `queueName` = `jobs`.queue
let `futName` = newFuture[`tp`](astToStr(`exp`))
let `idName` = `futName`.id()
`jobs`.futures[`idName`] = `futName`

4
tests/tjobs.nim
View File

@ -24,10 +24,12 @@ suite "async tests":
# var tp = Taskpool.new(num_threads = 2) # Default to the number of hardware threads.
# var queue = newSignalQueue[float]()
var jobs = newJobQueue[float]()
var tp = Taskpool.new(num_threads = 2) # Default to the number of hardware threads.
asyncTest "test":
var jobs = newJobQueue[float](taskpool = tp)
echo "\nstart"
let res = await jobs.submit(addNums(1.0, 2.0,))