mirror of
https://github.com/ruby/ruby.git
synced 2022-11-09 12:17:21 -05:00
6064132c42
git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@60139 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
57 lines
1.2 KiB
Ruby
57 lines
1.2 KiB
Ruby
# frozen_string_literal: false
|
|
require 'test/unit'
|
|
|
|
class TestThreadGroup < Test::Unit::TestCase
|
|
def test_thread_init
|
|
thgrp = ThreadGroup.new
|
|
th = Thread.new{
|
|
thgrp.add(Thread.current)
|
|
Thread.new{sleep 1}
|
|
}.value
|
|
assert_equal(thgrp, th.group)
|
|
ensure
|
|
th.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
|