58 lines
1.2 KiB
Ruby
58 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
|