diff options
author | kosaki <kosaki@b2dd03c8-39d4-4d8f-98ff-823fe69b080e> | 2012-12-05 19:37:37 +0000 |
---|---|---|
committer | kosaki <kosaki@b2dd03c8-39d4-4d8f-98ff-823fe69b080e> | 2012-12-05 19:37:37 +0000 |
commit | def63c3466939161f2459f6489815b444bbde8a3 (patch) | |
tree | 2d28e53a791ae47023aa2aa893e641896d08262a /test/ruby | |
parent | 84cfe8f8d669c3b8bdadc8a819d6482b890c5e24 (diff) | |
download | ruby-def63c3466939161f2459f6489815b444bbde8a3.tar.gz |
* io.c (io_binwrite): check interrupt before io issue.
* test/ruby/test_thread.rb (test_async_interrupt_and_io):
test for the above.
git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@38224 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
Diffstat (limited to 'test/ruby')
-rw-r--r-- | test/ruby/test_thread.rb | 20 |
1 files changed, 20 insertions, 0 deletions
diff --git a/test/ruby/test_thread.rb b/test/ruby/test_thread.rb index 6bec7dfc34..b82cae4cb7 100644 --- a/test/ruby/test_thread.rb +++ b/test/ruby/test_thread.rb @@ -617,6 +617,26 @@ class TestThread < Test::Unit::TestCase assert_equal(:ok,r) end + def test_async_interrupt_and_io + assert_in_out_err([], <<-INPUT, %w(ok), []) + th_waiting = true + + t = Thread.new { + Thread.async_interrupt_timing(RuntimeError => :on_blocking) { + nil while th_waiting + # async interrupt should be raised _before_ writing puts arguments + puts "ng" + } + } + + sleep 0.1 + t.raise RuntimeError + th_waiting = false + t.join rescue nil + puts "ok" + INPUT + end + def test_async_interrupted? q = Queue.new Thread.async_interrupt_timing(RuntimeError => :defer){ |