added a testcase for getThreadId
This commit is contained in:
parent
c32c39f1de
commit
86833b53a4
1 changed files with 5 additions and 0 deletions
|
|
@ -14,8 +14,11 @@ var
|
|||
producer, consumer: Thread[void]
|
||||
chan: Channel[TMsg]
|
||||
printedLines = 0
|
||||
prodId: int
|
||||
consId: int
|
||||
|
||||
proc consume() {.thread.} =
|
||||
consId = getThreadId()
|
||||
while true:
|
||||
var x = recv(chan)
|
||||
if x.k == mEof: break
|
||||
|
|
@ -23,6 +26,7 @@ proc consume() {.thread.} =
|
|||
atomicInc(printedLines)
|
||||
|
||||
proc produce() {.thread.} =
|
||||
prodId = getThreadId()
|
||||
var m: TMsg
|
||||
var input = open("readme.txt")
|
||||
var line = ""
|
||||
|
|
@ -40,5 +44,6 @@ joinThread(consumer)
|
|||
joinThread(producer)
|
||||
|
||||
close(chan)
|
||||
doAssert prodId != consId
|
||||
echo printedLines
|
||||
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue