summary refs log blame commit diff stats
path: root/tests/threads/ttryrecv.nim
blob: fcff94e789ab2474ab4bcf252e80c6cac7146a8e (plain) (tree)
1
2
3
4
5
6
7
8
9
10
           
                     




                               
                       

                    
                             

                                       
                   
                   


                   
                    
                    













                                              
               
           
discard """
  matrix: "--mm:refc"
  outputsub: "channel is empty"
"""

# bug #1816

from random import rand
from os import sleep

type PComm = ptr Channel[int]

proc doAction(outC: PComm) {.thread.} =
  for i in 0 ..< 5:
    sleep(rand(50))
    send(outC[], i)

var
  thr: Thread[PComm]
  chan: Channel[int]

open(chan)
createThread[PComm](thr, doAction, addr(chan))

while true:
  let (flag, x) = tryRecv(chan)
  if flag:
    echo("received from chan: " & $x)
  else:
    echo "channel is empty"
    break

echo "Finished listening"

joinThread(thr)
close(chan)