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

taskpools examples

Browse Source
This commit is contained in:
Jaremy Creechley 2024-02-08 20:31:59 -07:00
parent 7fe5d512bb
commit 5667a679e8
No known key found for this signature in database
GPG Key ID: 4E66FB67B21D3300
1 changed files with 39 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

40
tests/tpools.nim
View File

@ -27,4 +27,42 @@ proc main() =
tp.shutdown()
# Compile with nim c -r -d:release --threads:on --outdir:build example.nim
main()
main()
when false:
let fut = newFlowVar(typeof(float))
proc taskpool_term(k: openArray[float]; fut: Flowvar[float]) {.nimcall.} =
let res = term(k)
readyWith(fut, res)
let taskNode = new(TaskNode, workerContext.currentTask) do:
type
ScratchObj_486539473 = object
k: seq[float]
fut: Flowvar[float]
let scratch_486539466 = cast[ptr ScratchObj_486539473](c_calloc(csize_t(1),
csize_t(16)))
if isNil(scratch_486539466):
raise
(ref OutOfMemDefect)(msg: "Could not allocate memory", parent: nil)
block:
var isoTemp_486539469 = isolate(`@`(args))
scratch_486539466.k = extract(isoTemp_486539469)
var isoTemp_486539471 = isolate(fut)
scratch_486539466.fut = extract(isoTemp_486539471)
proc taskpool_term_486539474(args: pointer) {.gcsafe, nimcall,
raises: [].} =
let objTemp_486539468 = cast[ptr ScratchObj_486539473](args)
let k_486539470 = objTemp_486539468.k
let fut_486539472 = objTemp_486539468.fut
taskpool_term(k_486539470, fut_486539472)
proc destroyScratch_486539475(args: pointer) {.gcsafe, nimcall,
raises: [].} =
let obj_486539476 = cast[ptr ScratchObj_486539473](args)
`=destroy`(obj_486539476[])
Task(callback: taskpool_term_486539474, args: scratch_486539466,
destroy: destroyScratch_486539475)
schedule(workerContext, taskNode)