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

refactoring

Browse Source
This commit is contained in:
Jaremy Creechley 2024-02-13 21:49:59 -07:00
parent 3727c4855b
commit fbad0e13a5
No known key found for this signature in database
GPG Key ID: 4E66FB67B21D3300
2 changed files with 1 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/apatheia/jobs.nim
View File

@ -72,6 +72,6 @@ template submit*[T](jobs: JobQueue[T], exp: untyped): Future[T] =
template jobWrapper*(task: untyped) = template jobWrapper*(task: untyped) =
template `task Wrapper`*(jobResult: JobResult[float], args: varargs[untyped]) = template `task Wrapper`*(jobResult: JobResult[float], args: varargs[untyped]) =
let res = unpackVarargs(`task`(args)) let res = unpackVarargs(`task`, args)
discard jobResult.queue.send((jobResult.id, res,)) discard jobResult.queue.send((jobResult.id, res,))

2
tests/tjobs.nim
View File

@ -20,8 +20,6 @@ proc addNums(jobResult: JobResult[float], a, b: float) =
let res = addNumsRaw(a, b) let res = addNumsRaw(a, b)
discard jobResult.queue.send((jobResult.id, res,)) discard jobResult.queue.send((jobResult.id, res,))
jobWrapper(addNumsRaw)
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.