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

setup jobs

Browse Source
This commit is contained in:
Jaremy Creechley 2024-02-09 23:11:55 -07:00
parent 49a050dca1
commit 7f18b83a09
No known key found for this signature in database
GPG Key ID: 4E66FB67B21D3300
1 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/apatheia/jobs.nim
View File

@ -1,5 +1,6 @@
import std/tables
import std/macros
import std/sequtils
import ./queues
@ -23,8 +24,13 @@ type
proc processJobs*(jobs: JobQueue) {.async.} =
while jobs.running:
echo "jobs running..."
let res = await jobs.queue.wait()
let res = get await jobs.queue.wait()
echo "jobs result: ", res.repr
echo "jobs futes: ", jobs.unsafeAddr.pointer.repr
echo "jobs futes: ", jobs.futures.keys().toSeq()
let (id, ret) = res
let fut = jobs.futures[id]
fut.complete(ret)
proc newJobQueue*[T](maxItems: int = 0, taskpool: Taskpool = Taskpool.new()): JobQueue[T] {.raises: [ApatheiaSignalErr].} =
result = JobQueue[T](queue: newSignalQueue[(uint, T)](maxItems), taskpool: taskpool, running: true)
@ -51,6 +57,7 @@ macro submitMacro*(tp: untyped, jobs: untyped, exp: untyped): untyped =
let `futName` = newFuture[`tp`](astToStr(`exp`))
let `idName` = `futName`.id()
`jobs`.futures[`idName`] = `futName`
echo "jobs added: ", `jobs`.unsafeAddr.pointer.repr, " => ", `jobs`.futures.keys().toSeq()
`jobs`.taskpool.spawn(`fncall`)
`futName`