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

tweak test

Browse Source
This commit is contained in:
Jaremy Creechley 2024-02-14 22:22:14 -07:00
parent 8e8a090b0b
commit d21ab3fecc
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
tests/ttasks.nim
View File

@ -5,7 +5,6 @@ import chronos/threadsync
import chronos/unittest2/asynctests import chronos/unittest2/asynctests
import taskpools import taskpools
import apatheia/queues
import apatheia/tasks import apatheia/tasks
proc addNums(a, b: float): float {.asyncTask.} = proc addNums(a, b: float): float {.asyncTask.} =
@ -20,14 +19,19 @@ proc addNumValues(vals: openArray[float]): float {.asyncTask.} =
suite "async tests": suite "async tests":
var tp = Taskpool.new(num_threads = 2) # Default to the number of hardware threads. var tp = Taskpool.new(num_threads = 2) # Default to the number of hardware threads.
var jobsVar = newJobQueue[float](taskpool = tp)
proc getJobs(): JobQueue[float] =
{.cast(gcsafe).}:
jobsVar
asyncTest "test addNums": asyncTest "test addNums":
var jobs = newJobQueue[float](taskpool = tp) let jobs = getJobs()
let res = await jobs.submit(addNums(1.0, 2.0,)) let res = await jobs.submit(addNums(1.0, 2.0,))
check res == 3.0 check res == 3.0
asyncTest "test addNumValues": asyncTest "test addNumValues":
var jobs = newJobQueue[float](taskpool = tp) let jobs = getJobs()
let args = @[1.0, 2.0, 3.0] let args = @[1.0, 2.0, 3.0]
let res = await jobs.submit(addNumValues(args)) let res = await jobs.submit(addNumValues(args))
check res == 6.0 check res == 6.0