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

more examples

Browse Source
This commit is contained in:
Jaremy Creechley 2024-02-21 23:41:11 -07:00
parent 7fcc8dba1b
commit 81f304f879
1 changed files with 9 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
tests/exampleGcFailures/exFailureSeq.nim
View File

@ -30,7 +30,7 @@ proc toSeqDataPtr*[T](data: seq[T]): SeqDataPtr[T] =
)
proc worker(data: SeqDataPtr[char], sig: ThreadSignalPtr) =
os.sleep(300)
os.sleep(1_0)
echo "running worker: "
echo "worker: ", data.toOpenArray()
for i, c in data.toOpenArray():
@ -41,22 +41,23 @@ proc runTest(tp: TaskPool, sig: ThreadSignalPtr) {.async.} =
## init
var obj = "hello world!".toSeq()
echo "spawn worker"
# echo "spawn worker"
tp.spawn worker(obj.toSeqDataPtr(), sig)
## adding fut.wait(100.milliseconds) creates memory issue
await wait(sig).wait(10.milliseconds)
await wait(sig).wait(1.milliseconds)
## just doing the wait is fine:
# await wait(sig)
proc runTests(tp: TaskPool, sig: ThreadSignalPtr) {.async.} =
for i in 1..10_000:
for i in 1..30_000:
try:
await runTest(tp, sig)
os.sleep(200)
except AsyncTimeoutError:
echo "looping..."
GC_fullCollect()
# os.sleep(1)
# echo "looping..."
# GC_fullCollect()
discard
suite "async tests":
var tp = Taskpool.new(num_threads = 2) # Default to the number of hardware threads.
@ -64,3 +65,4 @@ suite "async tests":
asyncTest "test":
await runTests(tp, sig)
os.sleep(10_000)