logos-storage/apatheia
1
0
Fork 0
mirror of https://github.com/logos-storage/apatheia.git synced 2026-01-07 15:33:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

add chronicles

Browse Source
This commit is contained in:
Jaremy Creechley 2024-02-14 21:10:36 -07:00
parent 2c4ed467e9
commit 28060d9d3d
2 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/apatheia/jobs.nim
View File

@ -6,9 +6,14 @@ import ./queues
import taskpools import taskpools
import chronos import chronos
import chronicles
export queues export queues
logScope:
# Lexical properties are typically assigned to a constant:
topics = "apatheia jobs"
## This module provides a simple way to submit jobs to taskpools ## This module provides a simple way to submit jobs to taskpools
## and getting a result returned via an async future. ## and getting a result returned via an async future.
## ##
@ -36,10 +41,9 @@ proc processJobs*[T](jobs: JobQueue[T]) {.async.} =
## and complete the associated futures. ## and complete the associated futures.
while jobs.running: while jobs.running:
echo "jobs running..." info "Processing jobs in job queue"
let res = await(jobs.queue.wait()).get() let res = await(jobs.queue.wait()).get()
echo "jobs result: ", res.repr debug "got job result", jobResult = res
echo "jobs futes: ", jobs.futures.unsafeAddr.pointer.repr, " => ", jobs.futures.keys().toSeq()
let (id, ret) = res let (id, ret) = res
var fut: Future[T] var fut: Future[T]
if jobs.futures.pop(id, fut): if jobs.futures.pop(id, fut):

1
tests/tjobs.nim
View File

@ -1,5 +1,6 @@
import std/os import std/os
import chronicles
import chronos import chronos
import chronos/threadsync import chronos/threadsync
import chronos/unittest2/asynctests import chronos/unittest2/asynctests