blob: d44196039f0a6743ae554c169cab5a857d4ec8df (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
|
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()
|