summaryrefslogtreecommitdiff
path: root/test/monitor
diff options
context:
space:
mode:
authorakr <akr@b2dd03c8-39d4-4d8f-98ff-823fe69b080e>2014-11-13 13:04:43 +0000
committerakr <akr@b2dd03c8-39d4-4d8f-98ff-823fe69b080e>2014-11-13 13:04:43 +0000
commitb19c39f94f5406b91142ae873b9912ee03a5ab31 (patch)
treeaf45b18f76b9f3822dd51c9f555993618b07f586 /test/monitor
parent3864eb828b37315d1e15f147bcfb4ff06566dcf6 (diff)
* test/monitor/test_monitor.rb: Use assert_join_threads.
git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@48401 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
Diffstat (limited to 'test/monitor')
-rw-r--r--test/monitor/test_monitor.rb132
1 files changed, 72 insertions, 60 deletions
diff --git a/test/monitor/test_monitor.rb b/test/monitor/test_monitor.rb
index 313ef23..451e26c 100644
--- a/test/monitor/test_monitor.rb
+++ b/test/monitor/test_monitor.rb
@@ -20,14 +20,16 @@ class TestMonitor < Test::Unit::TestCase
end
@monitor.exit
}
- @monitor.enter
- queue.enq(nil)
- for i in 1 .. 5
- ary.push(i)
- Thread.pass
- end
- @monitor.exit
- th.join
+ th2 = Thread.start {
+ @monitor.enter
+ queue.enq(nil)
+ for i in 1 .. 5
+ ary.push(i)
+ Thread.pass
+ end
+ @monitor.exit
+ }
+ assert_join_threads([th, th2])
assert_equal((1..10).to_a, ary)
end
@@ -43,14 +45,16 @@ class TestMonitor < Test::Unit::TestCase
end
end
}
- @monitor.synchronize do
- queue.enq(nil)
- for i in 1 .. 5
- ary.push(i)
- Thread.pass
+ th2 = Thread.start {
+ @monitor.synchronize do
+ queue.enq(nil)
+ for i in 1 .. 5
+ ary.push(i)
+ Thread.pass
+ end
end
- end
- th.join
+ }
+ assert_join_threads([th, th2])
assert_equal((1..10).to_a, ary)
end
@@ -69,18 +73,18 @@ class TestMonitor < Test::Unit::TestCase
ary << :t2
}
}
- @monitor.synchronize do
- queue.enq(nil)
- queue.enq(nil)
- assert_equal([], ary)
- t1.kill
- t2.kill
- ary << :main
- end
- assert_equal([:main], ary)
- ensure
- t1.join
- t2.join
+ t3 = Thread.start {
+ @monitor.synchronize do
+ queue.enq(nil)
+ queue.enq(nil)
+ assert_equal([], ary)
+ t1.kill
+ t2.kill
+ ary << :main
+ end
+ assert_equal([:main], ary)
+ }
+ assert_join_threads([t1, t2, t3])
end
def test_try_enter
@@ -94,15 +98,17 @@ class TestMonitor < Test::Unit::TestCase
@monitor.exit
queue2.enq(nil)
}
- assert_equal(true, @monitor.try_enter)
- @monitor.exit
- queue1.enq(nil)
- queue2.deq
- assert_equal(false, @monitor.try_enter)
- queue1.enq(nil)
- queue2.deq
- assert_equal(true, @monitor.try_enter)
- th.join
+ th2 = Thread.start {
+ assert_equal(true, @monitor.try_enter)
+ @monitor.exit
+ queue1.enq(nil)
+ queue2.deq
+ assert_equal(false, @monitor.try_enter)
+ queue1.enq(nil)
+ queue2.deq
+ assert_equal(true, @monitor.try_enter)
+ }
+ assert_join_threads([th, th2])
end
def test_cond
@@ -117,14 +123,16 @@ class TestMonitor < Test::Unit::TestCase
cond.signal
end
end
- @monitor.synchronize do
- queue1.enq(nil)
- assert_equal("foo", a)
- result1 = cond.wait
- assert_equal(true, result1)
- assert_equal("bar", a)
+ th2 = Thread.start do
+ @monitor.synchronize do
+ queue1.enq(nil)
+ assert_equal("foo", a)
+ result1 = cond.wait
+ assert_equal(true, result1)
+ assert_equal("bar", a)
+ end
end
- th.join
+ assert_join_threads([th, th2])
end
def test_timedwait
@@ -138,14 +146,16 @@ class TestMonitor < Test::Unit::TestCase
cond.signal
end
end
- @monitor.synchronize do
- queue2.enq(nil)
- assert_equal("foo", b)
- result2 = cond.wait(0.1)
- assert_equal(true, result2)
- assert_equal("bar", b)
+ th2 = Thread.start do
+ @monitor.synchronize do
+ queue2.enq(nil)
+ assert_equal("foo", b)
+ result2 = cond.wait(0.1)
+ assert_equal(true, result2)
+ assert_equal("bar", b)
+ end
end
- th.join
+ assert_join_threads([th, th2])
c = "foo"
queue3 = Queue.new
@@ -156,17 +166,19 @@ class TestMonitor < Test::Unit::TestCase
cond.signal
end
end
- @monitor.synchronize do
- assert_equal("foo", c)
- result3 = cond.wait(0.1)
- assert_equal(true, result3) # wait always returns true in Ruby 1.9
- assert_equal("foo", c)
- queue3.enq(nil)
- result4 = cond.wait
- assert_equal(true, result4)
- assert_equal("bar", c)
+ th2 = Thread.start do
+ @monitor.synchronize do
+ assert_equal("foo", c)
+ result3 = cond.wait(0.1)
+ assert_equal(true, result3) # wait always returns true in Ruby 1.9
+ assert_equal("foo", c)
+ queue3.enq(nil)
+ result4 = cond.wait
+ assert_equal(true, result4)
+ assert_equal("bar", c)
+ end
end
- th.join
+ assert_join_threads([th, th2])
# d = "foo"
# cumber_thread = Thread.start {