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
71
72
73
74
75
76
77
78
79
80
81
82
|
require "spec_helper"
require "bunny/concurrent/condition"
describe Bunny::Concurrent::Condition do
describe "#wait" do
50.times do |i|
it "blocks current thread until notified (take #{i})" do
condition = described_class.new
xs = []
t = Thread.new do
xs << :notified
sleep 0.2
condition.notify
end
t.abort_on_exception = true
condition.wait
expect(xs).to eq [:notified]
end
end
end
describe "#notify" do
50.times do |i|
it "notifies a single thread waiting on the latch (take #{i})" do
mutex = Mutex.new
condition = described_class.new
xs = []
t1 = Thread.new do
condition.wait
mutex.synchronize { xs << :notified1 }
end
t1.abort_on_exception = true
t2 = Thread.new do
condition.wait
mutex.synchronize { xs << :notified2 }
end
t2.abort_on_exception = true
sleep 0.2
condition.notify
sleep 0.5
expect(xs).to satisfy { |ys| ys.size == 1 && (ys.include?(:notified1) || ys.include?(:notified2)) }
end
end
end
describe "#notify_all" do
let(:n) { 30 }
50.times do |i|
it "notifies all the threads waiting on the latch (take #{i})" do
mutex = Mutex.new
condition = described_class.new
@xs = []
n.times do |i|
t = Thread.new do
condition.wait
mutex.synchronize { @xs << "notified#{i + 1}".to_sym }
end
t.abort_on_exception = true
end
sleep 0.5
condition.notify_all
sleep 0.5
n.times do |i|
item = "notified#{i + 1}".to_sym
expect(@xs).to include item
end
end
end
end
end
|
