From a6b82b47e81c807f53385df62392b0d245044ed8 Mon Sep 17 00:00:00 2001 From: Jaremy Creechley Date: Mon, 12 Feb 2024 13:35:01 -0700 Subject: [PATCH] updates --- src/apatheia/jobs.nim | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) diff --git a/src/apatheia/jobs.nim b/src/apatheia/jobs.nim index 69b23b1..35a47f3 100644 --- a/src/apatheia/jobs.nim +++ b/src/apatheia/jobs.nim @@ -26,8 +26,7 @@ proc processJobs*(jobs: JobQueue) {.async.} = echo "jobs running..." 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() + echo "jobs futes: ", jobs.futures.unsafeAddr.pointer.repr, " => ", jobs.futures.keys().toSeq() let (id, ret) = res let fut = jobs.futures[id] fut.complete(ret) @@ -35,7 +34,7 @@ proc processJobs*(jobs: JobQueue) {.async.} = 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() + echo "jobs added: ", jobs.futures.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].} = @@ -49,8 +48,7 @@ macro submitMacro*(tp: untyped, jobs: untyped, exp: untyped): untyped = let futName = genSym(nskLet, "fut") let idName = genSym(nskLet, "id") let nm = newLit(repr(exp)) - let queueExpr = quote do: - `jobs`.queue + let queueExpr = quote do: `jobs`.queue var fncall = nnkCall.newTree(exp[0]) fncall.add(queueExpr) fncall.add(idName)