mirror of
https://github.com/logos-storage/apatheia.git
synced 2026-01-04 22:13:13 +00:00
cleanup futures
This commit is contained in:
parent
d75c2d8a19
commit
69ce89f43a
@ -58,7 +58,7 @@ proc newJobQueue*[T](maxItems: int = 0, taskpool: Taskpool = Taskpool.new()): Jo
|
||||
result = JobQueue[T](queue: newSignalQueue[(uint, T)](maxItems), taskpool: taskpool, running: true)
|
||||
asyncSpawn(processJobs(result))
|
||||
|
||||
macro submitMacro*(tp: untyped, jobs: untyped, exp: untyped): untyped =
|
||||
macro submitMacro(tp: untyped, jobs: untyped, exp: untyped): untyped =
|
||||
## modifies the call expression to include the job queue and
|
||||
## the job id parameters
|
||||
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user