From 33a837cf65a19dd61b0e0c4250b2e1b1cbe9130e Mon Sep 17 00:00:00 2001 From: Jaremy Creechley Date: Fri, 9 Feb 2024 23:04:13 -0700 Subject: [PATCH] setup jobs --- src/apatheia/jobs.nim | 2 +- tests/tjobs.nim | 4 +++- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/src/apatheia/jobs.nim b/src/apatheia/jobs.nim index f5e4ae2..06d68a3 100644 --- a/src/apatheia/jobs.nim +++ b/src/apatheia/jobs.nim @@ -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` diff --git a/tests/tjobs.nim b/tests/tjobs.nim index c559e44..aa22f5b 100644 --- a/tests/tjobs.nim +++ b/tests/tjobs.nim @@ -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,))