mirror of
https://github.com/ruby/ruby.git
synced 2022-11-09 12:17:21 -05:00
* test/thread/test_thread.rb: Add a test script for the `thread'
library. This should result in failure as of now with ext/thread; submitted by: Sylvain Joyeux <sylvain.joyeux AT m4x.org> in [ruby-core:10598]. git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/branches/ruby_1_8@12067 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
This commit is contained in:
parent
1fbbef5d73
commit
89150c9ecb
2 changed files with 74 additions and 0 deletions
|
@ -1,3 +1,10 @@
|
|||
Fri Mar 16 16:17:27 2007 Akinori MUSHA <knu@iDaemons.org>
|
||||
|
||||
* test/thread/test_thread.rb: Add a test script for the `thread'
|
||||
library. This should result in failure as of now with
|
||||
ext/thread; submitted by: Sylvain Joyeux <sylvain.joyeux AT
|
||||
m4x.org> in [ruby-core:10598].
|
||||
|
||||
Wed Mar 14 12:30:00 2007 Shigeo Kobayashi <shigeo@tinyforest.jp>
|
||||
|
||||
* ext/bigdecimal/bigdecimal.c: BigDecimal("-.31") is now
|
||||
|
|
67
test/thread/test_thread.rb
Normal file
67
test/thread/test_thread.rb
Normal file
|
@ -0,0 +1,67 @@
|
|||
require 'thread'
|
||||
require 'test/unit'
|
||||
|
||||
class TC_Thread < Test::Unit::TestCase
|
||||
def setup
|
||||
Thread.abort_on_exception = true
|
||||
end
|
||||
def teardown
|
||||
Thread.abort_on_exception = false
|
||||
end
|
||||
def test_condvar
|
||||
mutex = Mutex.new
|
||||
condvar = ConditionVariable.new
|
||||
result = []
|
||||
mutex.synchronize do
|
||||
t = Thread.new do
|
||||
mutex.synchronize do
|
||||
result << 1
|
||||
condvar.signal
|
||||
end
|
||||
end
|
||||
|
||||
result << 0
|
||||
condvar.wait(mutex)
|
||||
result << 2
|
||||
t.join
|
||||
end
|
||||
assert_equal([0, 1, 2], result)
|
||||
end
|
||||
|
||||
def test_condvar_wait_not_owner
|
||||
mutex = Mutex.new
|
||||
condvar = ConditionVariable.new
|
||||
|
||||
assert_raises(ThreadError) { condvar.wait(mutex) }
|
||||
end
|
||||
|
||||
def test_condvar_wait_exception_handling
|
||||
# Calling wait in the only thread running should raise a ThreadError of
|
||||
# 'stopping only thread'
|
||||
mutex = Mutex.new
|
||||
condvar = ConditionVariable.new
|
||||
|
||||
Thread.abort_on_exception = false
|
||||
|
||||
locked = false
|
||||
thread = Thread.new do
|
||||
mutex.synchronize do
|
||||
begin
|
||||
condvar.wait(mutex)
|
||||
rescue Exception
|
||||
locked = mutex.locked?
|
||||
raise
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
while !thread.stop?
|
||||
sleep(0.1)
|
||||
end
|
||||
|
||||
thread.raise Interrupt, "interrupt a dead condition variable"
|
||||
assert_raises(Interrupt) { thread.value }
|
||||
assert(locked)
|
||||
end
|
||||
end
|
||||
|
Loading…
Add table
Add a link
Reference in a new issue