summaryrefslogtreecommitdiff
path: root/spec/ruby/library/conditionvariable/signal_spec.rb
blob: 04b249a6c6ff0514b1dc75ee35a327f0c0e10976 (plain)
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
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
require_relative '../../spec_helper'
require 'thread'

describe "ConditionVariable#signal" do
  it "returns self if nothing to signal" do
    cv = ConditionVariable.new
    cv.signal.should == cv
  end

  it "returns self if something is waiting for a signal" do
    m = Mutex.new
    cv = ConditionVariable.new
    in_synchronize = false

    th = Thread.new do
      m.synchronize do
        in_synchronize = true
        cv.wait(m)
      end
    end

    # wait for m to acquire the mutex
    Thread.pass until in_synchronize
    # wait until th is sleeping (ie waiting)
    Thread.pass while th.status and th.status != "sleep"

    m.synchronize { cv.signal }.should == cv

    th.join
  end

  it "releases the first thread waiting in line for this resource" do
    m = Mutex.new
    cv = ConditionVariable.new
    threads = []
    r1 = []
    r2 = []

    # large number to attempt to cause race conditions
    100.times do |i|
      threads << Thread.new(i) do |tid|
        m.synchronize do
          r1 << tid
          cv.wait(m)
          r2 << tid
        end
      end
    end

    # wait for all threads to acquire the mutex the first time
    Thread.pass until m.synchronize { r1.size == threads.size }
    # wait until all threads are sleeping (ie waiting)
    Thread.pass until threads.all? {|th| th.status == "sleep" }

    r2.should be_empty
    100.times do |i|
      m.synchronize do
        cv.signal
      end
      Thread.pass until r2.size == i+1
    end

    threads.each {|t| t.join }

    # ensure that all the threads that went into the cv.wait are
    # released in the same order
    r2.should == r1
  end

  it "allows control to be passed between a pair of threads" do
    m = Mutex.new
    cv = ConditionVariable.new
    repeats = 100
    in_synchronize = false

    t1 = Thread.new do
      m.synchronize do
        in_synchronize = true
        repeats.times do
          cv.wait(m)
          cv.signal
        end
      end
    end

    # Make sure t1 is waiting for a signal before launching t2.
    Thread.pass until in_synchronize
    Thread.pass until t1.status == 'sleep'

    t2 = Thread.new do
      m.synchronize do
        repeats.times do
          cv.signal
          cv.wait(m)
        end
      end
    end

    # Check that both threads terminated without exception
    t1.join
    t2.join
    m.locked?.should == false
  end
end