mirror of
https://github.com/logos-storage/apatheia.git
synced 2026-01-02 13:03:11 +00:00
61 lines
1.5 KiB
Nim
61 lines
1.5 KiB
Nim
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..1:
|
|
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)
|