path: root/tests/concurrency/tnodeadlocks.nim

discard """
  outputsub: "101"
  cmd: "nimrod $target --hints:on --threads:on $options $file"
"""

import os, locks

const
  noDeadlocks = defined(preventDeadlocks)

var
  thr: array [0..5, TThread[tuple[a, b: int]]]
  L, M, N: TLock

proc doNothing() = discard

proc threadFunc(interval: tuple[a, b: int]) {.thread.} = 
  doNothing()
  for i in interval.a..interval.b: 
    when nodeadlocks:
      case i mod 6
      of 0:
        Acquire(L) # lock stdout
        Acquire(M)
        Acquire(N)
      of 1:
        Acquire(L)
        Acquire(N) # lock stdout
        Acquire(M)
      of 2:
        Acquire(M)
        Acquire(L)
        Acquire(N)
      of 3:
        Acquire(M)
        Acquire(N)
        Acquire(L)
      of 4:
        Acquire(N)
        Acquire(M)
        Acquire(L)
      of 5:
        Acquire(N)
        Acquire(L)
        Acquire(M)
      else: assert false
    else:
      Acquire(L) # lock stdout
      Acquire(M)
      
    echo i
    os.sleep(10)
    when nodeadlocks:
      echo "deadlocks prevented: ", deadlocksPrevented
    when nodeadlocks:
      Release(N)
    Release(M)
    Release(L)

InitLock(L)
InitLock(M)
InitLock(N)

proc main =
  for i in 0..high(thr):
    createThread(thr[i], threadFunc, (i*100, i*100+50))
  joinThreads(thr)

main()