This commit is contained in:
Jaremy Creechley 2024-02-21 22:09:34 -07:00
parent 891e492775
commit f7801cfad6

View File

@ -15,13 +15,14 @@ type
proc worker(data: ptr OpenArrayHolder[char], queue: SignalQueue[int]) = proc worker(data: ptr OpenArrayHolder[char], queue: SignalQueue[int]) =
os.sleep(1_000) os.sleep(1_000)
assert data[].data != nil
echo "worker: ", data[].toOpenArray() echo "worker: ", data[].toOpenArray()
discard queue.send(data[].toOpenArray().len()) discard queue.send(data[].toOpenArray().len())
proc finalizer(obj: DataObj) = proc finalizer(obj: DataObj) =
echo "FINALIZE!!" echo "FINALIZE!!"
obj.holder.data.dealloc() obj.holder.data.dealloc()
# obj.holder.data = nil obj.holder.data = nil
proc runTest(tp: TaskPool, queue: SignalQueue[int]) {.async.} = proc runTest(tp: TaskPool, queue: SignalQueue[int]) {.async.} =
## init ## init
@ -49,7 +50,7 @@ suite "async tests":
try: try:
await runTest(tp, queue) await runTest(tp, queue)
except AsyncTimeoutError as err: except AsyncTimeoutError:
echo "Run GC" echo "Run GC"
GC_fullCollect() GC_fullCollect()
os.sleep(2_000) os.sleep(2_000)