mirror of
https://github.com/logos-storage/apatheia.git
synced 2026-01-04 05:53:11 +00:00
add ptr seq-seq example
This commit is contained in:
parent
44df47de2a
commit
5fd1e789bb
60
tests/exampleGcFailures/exNoFailurePtrSeqSeq.nim
Normal file
60
tests/exampleGcFailures/exNoFailurePtrSeqSeq.nim
Normal file
@ -0,0 +1,60 @@
|
||||
import std/os
|
||||
import std/sequtils
|
||||
import chronos
|
||||
import chronos/threadsync
|
||||
import chronos/unittest2/asynctests
|
||||
import taskpools
|
||||
|
||||
## create a probablistically likely failure of
|
||||
## using sequence memory from another thread
|
||||
## with refc.
|
||||
##
|
||||
## However, unlike `exFailure.nim`, this can take
|
||||
## a while to run.
|
||||
##
|
||||
## It may not always produce an error either, but
|
||||
## generally does so in a few seconds of running.
|
||||
##
|
||||
|
||||
proc worker(data: ptr seq[seq[char]], sig: ThreadSignalPtr) =
|
||||
# os.sleep(100)
|
||||
echo "running worker: "
|
||||
echo "worker: ", data.pointer.repr
|
||||
echo "worker: ", data[]
|
||||
# for i, d in data:
|
||||
# for j, c in d:
|
||||
# data[i][j] = char(c.uint8 + 10)
|
||||
GC_fullCollect()
|
||||
discard sig.fireSync()
|
||||
|
||||
proc runTest(tp: TaskPool, sig: ThreadSignalPtr, i: int) {.async.} =
|
||||
## init
|
||||
# await sleepAsync(10.milliseconds)
|
||||
var obj1 = ("hello world! " & $i).toSeq()
|
||||
var obj2 = "goodbye denver!".toSeq()
|
||||
var data = @[obj1, obj2]
|
||||
|
||||
# echo "spawn worker"
|
||||
tp.spawn worker(addr data, sig)
|
||||
|
||||
await wait(sig)
|
||||
echo "data: ", data.addr.pointer.repr
|
||||
echo "data: ", data
|
||||
echo ""
|
||||
|
||||
proc runTests(tp: TaskPool, sig: ThreadSignalPtr) {.async.} =
|
||||
var futs = newSeq[Future[void]]()
|
||||
for i in 1..40_000:
|
||||
let f = runTest(tp, sig, i)
|
||||
# futs.add f
|
||||
await f
|
||||
GC_fullCollect()
|
||||
await allFutures(futs)
|
||||
|
||||
suite "async tests":
|
||||
var tp = Taskpool.new(num_threads = 4) # Default to the number of hardware threads.
|
||||
let sig = ThreadSignalPtr.new().get()
|
||||
|
||||
asyncTest "test":
|
||||
await runTests(tp, sig)
|
||||
# os.sleep(10_000)
|
||||
@ -16,11 +16,11 @@ import taskpools
|
||||
## generally does so in a few seconds of running.
|
||||
##
|
||||
|
||||
proc worker(data: seq[seq[char]], sig: ThreadSignalPtr) =
|
||||
proc worker(data: ptr seq[seq[char]], sig: ThreadSignalPtr) =
|
||||
# os.sleep(100)
|
||||
echo "running worker: "
|
||||
echo "worker: ", data.unsafeAddr.pointer.repr
|
||||
echo "worker: ", data
|
||||
echo "worker: ", data.pointer.repr
|
||||
echo "worker: ", data[]
|
||||
# for i, d in data:
|
||||
# for j, c in d:
|
||||
# data[i][j] = char(c.uint8 + 10)
|
||||
@ -35,7 +35,7 @@ proc runTest(tp: TaskPool, sig: ThreadSignalPtr, i: int) {.async.} =
|
||||
var data = @[obj1, obj2]
|
||||
|
||||
# echo "spawn worker"
|
||||
tp.spawn worker(data, sig)
|
||||
tp.spawn worker(addr data, sig)
|
||||
|
||||
await wait(sig)
|
||||
echo "data: ", data.addr.pointer.repr
|
||||
Loading…
x
Reference in New Issue
Block a user