diff --git a/tests/tjobs.nim b/tests/tjobs.nim index b6cdf1c..8888d8e 100644 --- a/tests/tjobs.nim +++ b/tests/tjobs.nim @@ -32,7 +32,7 @@ suite "async tests": var jobs = newJobQueue[float](taskpool = tp) echo "\nstart" - let res = await jobs.submit(addNums2(1.0, 2.0,)) + let res = await jobs.submit(addNums(1.0, 2.0,)) # await sleepAsync(100.milliseconds) echo "result: ", res.repr diff --git a/tests/ttasks.nim b/tests/ttasks.nim index 235ac8c..6719b5c 100644 --- a/tests/ttasks.nim +++ b/tests/ttasks.nim @@ -17,15 +17,11 @@ proc addNums(a, b: float): float {.asyncTask.} = echo "adding: ", a, " + ", b return a + b -# proc addNums(jobResult: JobResult[float], a, b: float) = -# let res = addNumsRaw(a, b) -# discard jobResult.queue.send((jobResult.id, res,)) - -# suite "async tests": -# 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,)) -# echo "result: ", res.repr -# check true +suite "async tests": + 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,)) + echo "result: ", res.repr + check true