mirror of
https://github.com/logos-storage/apatheia.git
synced 2026-01-07 15:33:09 +00:00
more experiments
This commit is contained in:
parent
6885d4410f
commit
989dc8963b
@ -30,7 +30,7 @@ proc toSeqDataPtr*[T](data: seq[T]): SeqDataPtr[T] =
|
|||||||
)
|
)
|
||||||
|
|
||||||
proc worker(data: seq[seq[char]], sig: ThreadSignalPtr) =
|
proc worker(data: seq[seq[char]], sig: ThreadSignalPtr) =
|
||||||
os.sleep(100)
|
# os.sleep(100)
|
||||||
echo "running worker: "
|
echo "running worker: "
|
||||||
echo "worker: ", data
|
echo "worker: ", data
|
||||||
# for i, d in data:
|
# for i, d in data:
|
||||||
@ -48,7 +48,7 @@ proc runTest(tp: TaskPool, sig: ThreadSignalPtr) {.async.} =
|
|||||||
# echo "spawn worker"
|
# echo "spawn worker"
|
||||||
tp.spawn worker(data, sig)
|
tp.spawn worker(data, sig)
|
||||||
|
|
||||||
# await wait(sig)
|
await wait(sig)
|
||||||
echo "data: ", data
|
echo "data: ", data
|
||||||
|
|
||||||
proc runTests(tp: TaskPool, sig: ThreadSignalPtr) {.async.} =
|
proc runTests(tp: TaskPool, sig: ThreadSignalPtr) {.async.} =
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user