This commit is contained in:
Jaremy Creechley 2024-02-16 14:30:55 -07:00
parent 2842aaaf02
commit 542e4f77f2

View File

@ -8,6 +8,7 @@ import taskpools
import apatheia/queues import apatheia/queues
import apatheia/jobs import apatheia/jobs
import apatheia/memholders
proc addNumsRaw(a, b: float): float = proc addNumsRaw(a, b: float): float =
os.sleep(50) os.sleep(50)
@ -49,6 +50,17 @@ suite "async tests":
let res = await jobs.submit(addNumValues(10.0, @[1.0.float, 2.0])) let res = await jobs.submit(addNumValues(10.0, @[1.0.float, 2.0]))
check res == 13.0 check res == 13.0
asyncTest "testing arrays":
var jobs = newJobQueue[float](taskpool = tp)
let fut1 = jobs.submit(addNumValues(10.0, @[1.0.float, 2.0]))
let fut2 = jobs.submit(addNumValues(20.0, @[3.0.float, 4.0]))
check retainedMemoryCount() == 2
let res1 = await fut1
let res2 = await fut2
check res1 == 13.0
check res2 == 27.0
check retainedMemoryCount() == 0
asyncTest "don't compile": asyncTest "don't compile":
check not compiles( check not compiles(
block: block: