mirror of
https://github.com/ruby/ruby.git
synced 2022-11-09 12:17:21 -05:00
* test/ruby/test_thread.rb (test_uninitialized, test_backtrace,
test_thread_timer_and_interrupt, test_thread_join_in_trap, test_thread_join_current, test_thread_join_main_thread, test_main_thread_status_at_exit, test_thread_status_in_trap, test_thread_status_raise_after_kill, test_mutex_owned, test_mutex_owned2): move these tests from TestThreadGroup class to TestThread becuase they are not thread group tests. * test/ruby/test_thread.rb (test_thread_status_raise_after_kill): add t.join. * test/ruby/test_threadgroup.rb: new file. moved ThreadGroup test form test_thread.rb. git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@38388 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
This commit is contained in:
parent
3074406bbe
commit
4bcfc17182
3 changed files with 83 additions and 60 deletions
16
ChangeLog
16
ChangeLog
|
@ -1,3 +1,19 @@
|
||||||
|
Sat Dec 15 08:05:56 2012 KOSAKI Motohiro <kosaki.motohiro@gmail.com>
|
||||||
|
|
||||||
|
* test/ruby/test_thread.rb (test_uninitialized, test_backtrace,
|
||||||
|
test_thread_timer_and_interrupt, test_thread_join_in_trap,
|
||||||
|
test_thread_join_current, test_thread_join_main_thread,
|
||||||
|
test_main_thread_status_at_exit, test_thread_status_in_trap,
|
||||||
|
test_thread_status_raise_after_kill, test_mutex_owned,
|
||||||
|
test_mutex_owned2): move these tests from TestThreadGroup class
|
||||||
|
to TestThread becuase they are not thread group tests.
|
||||||
|
|
||||||
|
* test/ruby/test_thread.rb (test_thread_status_raise_after_kill):
|
||||||
|
add t.join.
|
||||||
|
|
||||||
|
* test/ruby/test_threadgroup.rb: new file. moved ThreadGroup test
|
||||||
|
form test_thread.rb.
|
||||||
|
|
||||||
Sat Dec 15 08:02:11 2012 KOSAKI Motohiro <kosaki.motohiro@gmail.com>
|
Sat Dec 15 08:02:11 2012 KOSAKI Motohiro <kosaki.motohiro@gmail.com>
|
||||||
|
|
||||||
* test/ruby/test_thread.rb (TestThread::Thread::new.): remove
|
* test/ruby/test_thread.rb (TestThread::Thread::new.): remove
|
||||||
|
|
|
@ -704,58 +704,6 @@ class TestThread < Test::Unit::TestCase
|
||||||
t.join
|
t.join
|
||||||
_eom
|
_eom
|
||||||
end
|
end
|
||||||
end
|
|
||||||
|
|
||||||
class TestThreadGroup < Test::Unit::TestCase
|
|
||||||
def test_thread_init
|
|
||||||
thgrp = ThreadGroup.new
|
|
||||||
Thread.new{
|
|
||||||
thgrp.add(Thread.current)
|
|
||||||
assert_equal(thgrp, Thread.new{sleep 1}.group)
|
|
||||||
}.join
|
|
||||||
end
|
|
||||||
|
|
||||||
def test_frozen_thgroup
|
|
||||||
thgrp = ThreadGroup.new
|
|
||||||
|
|
||||||
t = Thread.new{1}
|
|
||||||
Thread.new{
|
|
||||||
thgrp.add(Thread.current)
|
|
||||||
thgrp.freeze
|
|
||||||
assert_raise(ThreadError) do
|
|
||||||
Thread.new{1}.join
|
|
||||||
end
|
|
||||||
assert_raise(ThreadError) do
|
|
||||||
thgrp.add(t)
|
|
||||||
end
|
|
||||||
assert_raise(ThreadError) do
|
|
||||||
ThreadGroup.new.add Thread.current
|
|
||||||
end
|
|
||||||
}.join
|
|
||||||
t.join
|
|
||||||
end
|
|
||||||
|
|
||||||
def test_enclosed_thgroup
|
|
||||||
thgrp = ThreadGroup.new
|
|
||||||
assert_equal(false, thgrp.enclosed?)
|
|
||||||
|
|
||||||
t = Thread.new{1}
|
|
||||||
Thread.new{
|
|
||||||
thgrp.add(Thread.current)
|
|
||||||
thgrp.enclose
|
|
||||||
assert_equal(true, thgrp.enclosed?)
|
|
||||||
assert_nothing_raised do
|
|
||||||
Thread.new{1}.join
|
|
||||||
end
|
|
||||||
assert_raise(ThreadError) do
|
|
||||||
thgrp.add t
|
|
||||||
end
|
|
||||||
assert_raise(ThreadError) do
|
|
||||||
ThreadGroup.new.add Thread.current
|
|
||||||
end
|
|
||||||
}.join
|
|
||||||
t.join
|
|
||||||
end
|
|
||||||
|
|
||||||
def test_uninitialized
|
def test_uninitialized
|
||||||
c = Class.new(Thread)
|
c = Class.new(Thread)
|
||||||
|
@ -871,23 +819,27 @@ Thread.new(Thread.current) {|mth|
|
||||||
t = Thread.new {
|
t = Thread.new {
|
||||||
begin
|
begin
|
||||||
ary << Thread.current.status
|
ary << Thread.current.status
|
||||||
sleep
|
sleep #1
|
||||||
ensure
|
ensure
|
||||||
begin
|
begin
|
||||||
ary << Thread.current.status
|
ary << Thread.current.status
|
||||||
sleep
|
sleep #2
|
||||||
ensure
|
ensure
|
||||||
ary << Thread.current.status
|
ary << Thread.current.status
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
}
|
}
|
||||||
|
|
||||||
sleep 0.01
|
begin
|
||||||
t.kill
|
sleep 0.01
|
||||||
sleep 0.01
|
t.kill # wake up sleep #1
|
||||||
t.raise
|
sleep 0.01
|
||||||
sleep 0.01
|
t.raise "wakeup" # wake up sleep #2
|
||||||
assert_equal(ary, ["run", "aborting", "aborting"])
|
sleep 0.01
|
||||||
|
assert_equal(ary, ["run", "aborting", "aborting"])
|
||||||
|
ensure
|
||||||
|
t.join rescue nil
|
||||||
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
def test_mutex_owned
|
def test_mutex_owned
|
||||||
|
|
55
test/ruby/test_threadgroup.rb
Normal file
55
test/ruby/test_threadgroup.rb
Normal file
|
@ -0,0 +1,55 @@
|
||||||
|
require 'test/unit'
|
||||||
|
require 'thread'
|
||||||
|
require_relative 'envutil'
|
||||||
|
|
||||||
|
class TestThreadGroup < Test::Unit::TestCase
|
||||||
|
def test_thread_init
|
||||||
|
thgrp = ThreadGroup.new
|
||||||
|
Thread.new{
|
||||||
|
thgrp.add(Thread.current)
|
||||||
|
assert_equal(thgrp, Thread.new{sleep 1}.group)
|
||||||
|
}.join
|
||||||
|
end
|
||||||
|
|
||||||
|
def test_frozen_thgroup
|
||||||
|
thgrp = ThreadGroup.new
|
||||||
|
|
||||||
|
t = Thread.new{1}
|
||||||
|
Thread.new{
|
||||||
|
thgrp.add(Thread.current)
|
||||||
|
thgrp.freeze
|
||||||
|
assert_raise(ThreadError) do
|
||||||
|
Thread.new{1}.join
|
||||||
|
end
|
||||||
|
assert_raise(ThreadError) do
|
||||||
|
thgrp.add(t)
|
||||||
|
end
|
||||||
|
assert_raise(ThreadError) do
|
||||||
|
ThreadGroup.new.add Thread.current
|
||||||
|
end
|
||||||
|
}.join
|
||||||
|
t.join
|
||||||
|
end
|
||||||
|
|
||||||
|
def test_enclosed_thgroup
|
||||||
|
thgrp = ThreadGroup.new
|
||||||
|
assert_equal(false, thgrp.enclosed?)
|
||||||
|
|
||||||
|
t = Thread.new{1}
|
||||||
|
Thread.new{
|
||||||
|
thgrp.add(Thread.current)
|
||||||
|
thgrp.enclose
|
||||||
|
assert_equal(true, thgrp.enclosed?)
|
||||||
|
assert_nothing_raised do
|
||||||
|
Thread.new{1}.join
|
||||||
|
end
|
||||||
|
assert_raise(ThreadError) do
|
||||||
|
thgrp.add t
|
||||||
|
end
|
||||||
|
assert_raise(ThreadError) do
|
||||||
|
ThreadGroup.new.add Thread.current
|
||||||
|
end
|
||||||
|
}.join
|
||||||
|
t.join
|
||||||
|
end
|
||||||
|
end
|
Loading…
Add table
Add a link
Reference in a new issue