logos-storage/apatheia
1
0
Fork 0
mirror of https://github.com/logos-storage/apatheia.git synced 2026-01-05 22:43:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

compile output test

Browse Source
This commit is contained in:
Jaremy Creechley 2024-02-14 23:21:52 -07:00
parent 7ffae54dbb
commit 144ace3393
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/apatheia/jobs.nim
View File

@ -94,10 +94,9 @@ macro submitMacro(tp: untyped, jobs: untyped, exp: untyped): untyped =
`jobs`.taskpool.spawn(`fncall`) `jobs`.taskpool.spawn(`fncall`)
`futName` `futName`
echo "\nSUBMIT MACRO::\n", result.repr when isMainModule:
echo "" echo "\nSUBMIT MACRO::\n", result.repr
echo "\nSUBMIT MACRO::\n", result.treeRepr echo ""
echo ""
template submit*[T](jobs: JobQueue[T], exp: untyped): Future[T] = template submit*[T](jobs: JobQueue[T], exp: untyped): Future[T] =
submitMacro(T, jobs, exp) submitMacro(T, jobs, exp)
@ -109,6 +108,7 @@ when isMainModule:
import chronos/unittest2/asynctests import chronos/unittest2/asynctests
import std/macros import std/macros
proc addNumValues(jobResult: JobResult[float], vals: openArray[float]) = proc addNumValues(jobResult: JobResult[float], vals: openArray[float]) =
os.sleep(100) os.sleep(100)
var res = 0.0 var res = 0.0
@ -124,7 +124,7 @@ when isMainModule:
expandMacros: expandMacros:
var jobs = newJobQueue[float](taskpool = tp) var jobs = newJobQueue[float](taskpool = tp)
let job = jobs.submit(addNumValues([1.0, 2.0])) let job = jobs.submit(addNumValues(@[1.0, 2.0]))
let res = await job let res = await job
check res == 3.0 check res == 3.0