diff options
Diffstat (limited to 'bootstraptest/test_thread.rb')
| -rw-r--r-- | bootstraptest/test_thread.rb | 151 |
1 files changed, 99 insertions, 52 deletions
diff --git a/bootstraptest/test_thread.rb b/bootstraptest/test_thread.rb index 7baa806a45..7ff5bb4a38 100644 --- a/bootstraptest/test_thread.rb +++ b/bootstraptest/test_thread.rb @@ -1,4 +1,14 @@ -# Thread and Fiber +show_limit %q{ + threads = [] + begin + threads << Thread.new{sleep} + + raise Exception, "skipping" if threads.count >= 10_000 + rescue Exception => error + puts "Thread count: #{threads.count} (#{error})" + break + end while true +} if false # disable to pass CI assert_equal %q{ok}, %q{ Thread.new{ @@ -25,8 +35,9 @@ rescue ThreadError => e :ok if /can't create Thread/ =~ e.message end } -assert_equal %q{5000}, %q{ - 5000.times{|e| +assert_equal %q{ok}, %q{ +begin + :ok if 5000 == 5000.times{|e| (1..2).map{ Thread.new{ } @@ -34,9 +45,13 @@ assert_equal %q{5000}, %q{ e.join() } } +rescue ThreadError => e + /can't create Thread/ =~ e.message ? :ok : e.message +end } -assert_equal %q{5000}, %q{ - 5000.times{|e| +assert_equal %q{ok}, %q{ +begin + :ok if 5000 == 5000.times{|e| (1..2).map{ Thread.new{ } @@ -44,6 +59,9 @@ assert_equal %q{5000}, %q{ e.join(1000000000) } } +rescue ThreadError => e + /can't create Thread/ =~ e.message ? :ok : e.message +end } assert_equal %q{ok}, %q{ begin @@ -85,7 +103,7 @@ assert_equal %q{ok}, %q{ ans = :ok end } - Thread.pass + Thread.pass until t.stop? t.kill t.join ans @@ -224,9 +242,22 @@ assert_equal 'true', %{ end } +assert_equal 'true', %{ + Thread.new{}.join + begin + Process.waitpid2 fork{ + Thread.new{ + sleep 0.1 + }.join + } + true + rescue NotImplementedError + true + end +} + assert_equal 'ok', %{ - open("zzz.rb", "w") do |f| - f.puts <<-END + File.write("zzz_t1.rb", <<-END) begin Thread.new { fork { GC.start } }.join pid, status = Process.wait2 @@ -235,22 +266,21 @@ assert_equal 'ok', %{ $result = :ok end END - end - require "./zzz.rb" + require "./zzz_t1.rb" $result } assert_finish 3, %{ - th = Thread.new {sleep 2} - th.join(1) + th = Thread.new {sleep 0.2} + th.join(0.1) th.join } assert_finish 3, %{ require 'timeout' - th = Thread.new {sleep 2} + th = Thread.new {sleep 0.2} begin - Timeout.timeout(1) {th.join} + Timeout.timeout(0.1) {th.join} rescue Timeout::Error end th.join @@ -276,7 +306,7 @@ assert_normal_exit %q{ assert_equal 'ok', %q{ def m t = Thread.new { while true; // =~ "" end } - sleep 0.1 + sleep 0.01 10.times { if /((ab)*(ab)*)*(b)/ =~ "ab"*7 return :ng if !$4 @@ -291,10 +321,6 @@ assert_equal 'ok', %q{ }, '[ruby-dev:34492]' assert_normal_exit %q{ - at_exit { Fiber.new{}.resume } -} - -assert_normal_exit %q{ g = enum_for(:local_variables) loop { g.next } }, '[ruby-dev:34128]' @@ -320,10 +346,6 @@ assert_normal_exit %q{ }, '[ruby-dev:34128]' assert_normal_exit %q{ - Fiber.new(&Object.method(:class_eval)).resume("foo") -}, '[ruby-dev:34128]' - -assert_normal_exit %q{ Thread.new("foo", &Object.method(:class_eval)).join }, '[ruby-dev:34128]' @@ -339,9 +361,10 @@ assert_equal 'ok', %q{ assert_equal 'ok', %q{ begin - m1, m2 = Mutex.new, Mutex.new - Thread.new { m1.lock; sleep 1; m2.lock } - m2.lock; sleep 1; m1.lock + m1, m2 = Thread::Mutex.new, Thread::Mutex.new + f1 = f2 = false + Thread.new { m1.lock; f2 = true; sleep 0.001 until f1; m2.lock } + m2.lock; f1 = true; sleep 0.001 until f2; m1.lock :ng rescue Exception :ok @@ -349,34 +372,34 @@ assert_equal 'ok', %q{ } assert_equal 'ok', %q{ - m = Mutex.new - Thread.new { m.lock }; sleep 1; m.lock + m = Thread::Mutex.new + Thread.new { m.lock }; sleep 0.1; m.lock :ok } assert_equal 'ok', %q{ - m = Mutex.new + m = Thread::Mutex.new Thread.new { m.lock }; m.lock :ok } assert_equal 'ok', %q{ - m = Mutex.new + m = Thread::Mutex.new Thread.new { m.lock }.join; m.lock :ok } assert_equal 'ok', %q{ - m = Mutex.new - Thread.new { m.lock; sleep 2 } - sleep 1; m.lock + m = Thread::Mutex.new + Thread.new { m.lock; sleep 0.2 } + sleep 0.1; m.lock :ok } assert_equal 'ok', %q{ - m = Mutex.new - Thread.new { m.lock; sleep 2; m.unlock } - sleep 1; m.lock + m = Thread::Mutex.new + Thread.new { m.lock; sleep 0.2; m.unlock } + sleep 0.1; m.lock :ok } @@ -397,20 +420,20 @@ assert_equal 'ok', %q{ } assert_equal 'ok', %{ - open("zzz.rb", "w") do |f| - f.puts <<-END + File.write("zzz_t2.rb", <<-'end;') # do begin - m = Mutex.new - Thread.new { m.lock; sleep 1 } - sleep 0.3 + m = Thread::Mutex.new parent = Thread.current + th1 = Thread.new { m.lock; sleep } + sleep 0.01 until th1.stop? Thread.new do - sleep 0.3 + sleep 0.01 until parent.stop? begin fork { GC.start } rescue Exception parent.raise $! end + th1.run end m.lock pid, status = Process.wait2 @@ -418,17 +441,16 @@ assert_equal 'ok', %{ rescue NotImplementedError $result = :ok end - END - end - require "./zzz.rb" + end; + require "./zzz_t2.rb" $result } assert_finish 3, %q{ require 'thread' - lock = Mutex.new - cond = ConditionVariable.new + lock = Thread::Mutex.new + cond = Thread::ConditionVariable.new t = Thread.new do lock.synchronize do cond.wait(lock) @@ -448,17 +470,42 @@ assert_finish 3, %q{ assert_equal 'ok', %q{ begin - Process.waitpid2(fork {sleep 1})[1].success? ? 'ok' : 'ng' + Process.waitpid2(fork {})[1].success? ? 'ok' : 'ng' rescue NotImplementedError 'ok' end } assert_equal 'foo', %q{ - f = proc {|s| /#{ sleep 1; s }/o } - [ Thread.new { f.call("foo"); nil }, - Thread.new { sleep 0.5; f.call("bar"); nil }, - ].each {|t| t.join } + i = 0 + Thread.start {sleep 1; exit!} + f = proc {|s, c| /#{c.call; s}/o } + th2 = Thread.new { + sleep 0.01 until i == 1 + i = 2 + f.call("bar", proc {sleep 2}); + nil + } + th1 = Thread.new { + f.call("foo", proc {i = 1; sleep 0.01 until i == 2; sleep 0.01}) + nil + } + [th1, th2].each {|t| t.join } GC.start f.call.source } + +assert_normal_exit %q{ + class C + def inspect + sleep 0.5 + 'C!!' + end + end + Thread.new{ + loop{ + p C.new + } + } + sleep 0.1 +}, timeout: 5 |