mirror of
https://github.com/logos-storage/apatheia.git
synced 2026-01-05 22:43:10 +00:00
more experiments
This commit is contained in:
parent
2f42f513c0
commit
6885d4410f
@ -37,7 +37,7 @@ proc worker(data: seq[seq[char]], sig: ThreadSignalPtr) =
|
|||||||
# for j, c in d:
|
# for j, c in d:
|
||||||
# d[j] = char(c.uint8 + 10)
|
# d[j] = char(c.uint8 + 10)
|
||||||
GC_fullCollect()
|
GC_fullCollect()
|
||||||
# discard sig.fireSync()
|
discard sig.fireSync()
|
||||||
|
|
||||||
proc runTest(tp: TaskPool, sig: ThreadSignalPtr) {.async.} =
|
proc runTest(tp: TaskPool, sig: ThreadSignalPtr) {.async.} =
|
||||||
## init
|
## init
|
||||||
@ -48,9 +48,6 @@ proc runTest(tp: TaskPool, sig: ThreadSignalPtr) {.async.} =
|
|||||||
# echo "spawn worker"
|
# echo "spawn worker"
|
||||||
tp.spawn worker(data, sig)
|
tp.spawn worker(data, sig)
|
||||||
|
|
||||||
## adding fut.wait(100.milliseconds) creates memory issue
|
|
||||||
# await wait(sig)
|
|
||||||
## just doing the wait is fine:
|
|
||||||
# await wait(sig)
|
# await wait(sig)
|
||||||
echo "data: ", data
|
echo "data: ", data
|
||||||
|
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user