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
|
# many threads, one mutex, many condvars
require 'thread'
m = Thread::Mutex.new
cv1 = Thread::ConditionVariable.new
cv2 = Thread::ConditionVariable.new
max = 1000
n = 100
waiting = 0
scvs = []
waiters = n.times.map do |i|
start_cv = Thread::ConditionVariable.new
scvs << start_cv
start_mtx = Thread::Mutex.new
start_mtx.synchronize do
th = Thread.new(start_mtx, start_cv) do |sm, scv|
m.synchronize do
sm.synchronize { scv.signal }
max.times do
cv2.signal if (waiting += 1) == n
cv1.wait(m)
end
end
end
start_cv.wait(start_mtx)
th
end
end
m.synchronize do
max.times do
cv2.wait(m) until waiting == n
waiting = 0
cv1.broadcast
end
end
waiters.each(&:join)
|
