mirror of
https://github.com/nim-lang/Nim.git
synced 2025-12-28 17:04:41 +00:00
75f01bd49f
The forward declarations cause `Exception` to be inferred - also,
`llrecv` is an internal implementation detail and the type of the
received item is controlled by generics, thus the ValueError raised
there seems out of place for the generic api.
(cherry picked from commit 91febf1f4c)
52 lines
1.1 KiB
Nim
52 lines
1.1 KiB
Nim
|
|
import std / [atomics, strutils, sequtils]
|
|
|
|
type
|
|
BackendMessage* = object
|
|
field*: seq[int]
|
|
|
|
var
|
|
chan1: Channel[BackendMessage]
|
|
chan2: Channel[BackendMessage]
|
|
|
|
chan1.open()
|
|
chan2.open()
|
|
|
|
proc routeMessage*(msg: BackendMessage) {.raises: [], gcsafe.} = # no exceptions!
|
|
discard chan2.trySend(msg)
|
|
|
|
var
|
|
recv: Thread[void]
|
|
stopToken: Atomic[bool]
|
|
|
|
proc recvMsg() {.raises: [], gcsafe.} = # no exceptions!
|
|
while not stopToken.load(moRelaxed):
|
|
let resp = chan1.tryRecv()
|
|
if resp.dataAvailable:
|
|
routeMessage(resp.msg)
|
|
echo "child consumes ", formatSize getOccupiedMem()
|
|
|
|
createThread[void](recv, recvMsg)
|
|
|
|
const MESSAGE_COUNT = 100
|
|
|
|
proc main() =
|
|
let msg: BackendMessage = BackendMessage(field: (0..500).toSeq())
|
|
for j in 0..0: #100:
|
|
echo "New iteration"
|
|
|
|
for _ in 1..MESSAGE_COUNT:
|
|
chan1.send(msg)
|
|
echo "After sending"
|
|
|
|
var counter = 0
|
|
while counter < MESSAGE_COUNT:
|
|
let resp = recv(chan2)
|
|
counter.inc
|
|
echo "After receiving ", formatSize getOccupiedMem()
|
|
|
|
stopToken.store true, moRelaxed
|
|
joinThreads(recv)
|
|
|
|
main()
|