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

setup jobs

Browse Source
This commit is contained in:
Jaremy Creechley 2024-02-12 13:29:16 -07:00
parent f55a4aa7e1
commit 13d5d5c241
No known key found for this signature in database
GPG Key ID: 4E66FB67B21D3300
1 changed files with 11 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
src/apatheia/jobs.nim
View File

@ -32,6 +32,12 @@ proc processJobs*(jobs: JobQueue) {.async.} =
let fut = jobs.futures[id]
fut.complete(ret)
proc createFuture*[T](jobs: JobQueue[T], name: static string): (uint, Future[T]) =
let fut = newFuture[T](name)
jobs.futures[fut.id()] = fut
echo "jobs added: ", jobs.unsafeAddr.pointer.repr, " => ", jobs.futures.keys().toSeq()
return (fut.id(), fut, )
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)
asyncSpawn(processJobs(result))
@ -44,20 +50,18 @@ macro submitMacro*(tp: untyped, jobs: untyped, exp: untyped): untyped =
let futName = genSym(nskLet, "fut")
let idName = genSym(nskLet, "id")
let queueName = genSym(nskLet, "queue")
let queueExpr = quote do:
`jobs`.queue
var fncall = nnkCall.newTree(exp[0])
fncall.add(queueName)
fncall.add(queueExpr)
fncall.add(idName)
for p in exp[1..^1]:
fncall.add(p)
echo "submit: ", fncall.treeRepr
let nm = newLit(repr(exp))
result = quote do:
let `queueName` = `jobs`.queue
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()
let (`idName`, `futName`) = createFuture(`jobs`, `nm`)
`jobs`.taskpool.spawn(`fncall`)
`futName`