1 files changed, 0 insertions, 178 deletions
diff --git a/test/thread/test_queue.rb b/test/thread/test_queue.rb
deleted file mode 100644
index 6b4f10c4d2..0000000000
--- a/test/thread/test_queue.rb
+++ /dev/null
@@ -1,178 +0,0 @@
-require 'test/unit'
-require 'thread'
-require 'tmpdir'
-require_relative '../ruby/envutil'
-
-class TestQueue < Test::Unit::TestCase
-  def test_queue
-    grind(5, 1000, 15, Queue)
-  end
-
-  def test_sized_queue
-    grind(5, 1000, 15, SizedQueue, 1000)
-  end
-
-  def grind(num_threads, num_objects, num_iterations, klass, *args)
-    from_workers = klass.new(*args)
-    to_workers = klass.new(*args)
-
-    workers = (1..num_threads).map {
-      Thread.new {
-        while object = to_workers.pop
-          from_workers.push object
-        end
-      }
-    }
-
-    Thread.new {
-      num_iterations.times {
-        num_objects.times { to_workers.push 99 }
-        num_objects.times { from_workers.pop }
-      }
-    }.join
-
-    num_threads.times { to_workers.push nil }
-    workers.each { |t| t.join }
-
-    assert_equal 0, from_workers.size
-    assert_equal 0, to_workers.size
-  end
-
-  def test_sized_queue_initialize
-    q = SizedQueue.new(1)
-    assert_equal 1, q.max
-    assert_raise(ArgumentError) { SizedQueue.new(0) }
-    assert_raise(ArgumentError) { SizedQueue.new(-1) }
-  end
-
-  def test_sized_queue_assign_max
-    q = SizedQueue.new(2)
-    assert_equal(2, q.max)
-    q.max = 1
-    assert_equal(1, q.max)
-    assert_raise(ArgumentError) { q.max = 0 }
-    assert_equal(1, q.max)
-    assert_raise(ArgumentError) { q.max = -1 }
-    assert_equal(1, q.max)
-  end
-
-  def test_queue_pop_interrupt
-    q = Queue.new
-    t1 = Thread.new { q.pop }
-    sleep 0.01 until t1.stop?
-    t1.kill.join
-    assert_equal(0, q.num_waiting)
-  end
-
-  def test_sized_queue_pop_interrupt
-    q = SizedQueue.new(1)
-    t1 = Thread.new { q.pop }
-    sleep 0.01 until t1.stop?
-    t1.kill.join
-    assert_equal(0, q.num_waiting)
-  end
-
-  def test_sized_queue_push_interrupt
-    q = SizedQueue.new(1)
-    q.push(1)
-    t1 = Thread.new { q.push(2) }
-    sleep 0.01 until t1.stop?
-    t1.kill.join
-    assert_equal(0, q.num_waiting)
-  end
-
-  def test_thr_kill
-    bug5343 = '[ruby-core:39634]'
-    Dir.mktmpdir {|d|
-      timeout = 30
-      total_count = 250
-      begin
-        assert_normal_exit(<<-"_eom", bug5343, {:timeout => timeout, :chdir=>d})
-          require "thread"
-          #{total_count}.times do |i|
-            open("test_thr_kill_count", "w") {|f| f.puts i }
-            queue = Queue.new
-            r, w = IO.pipe
-            th = Thread.start {
-              queue.push(nil)
-              r.read 1
-            }
-            queue.pop
-            th.kill
-            th.join
-          end
-        _eom
-      rescue Timeout::Error
-        count = File.read("#{d}/test_thr_kill_count").to_i
-        flunk "only #{count}/#{total_count} done in #{timeout} seconds."
-      end
-    }
-  end
-
-  def test_sized_queue_clear
-    # Fill queue, then test that SizedQueue#clear wakes up all waiting threads
-    sq = SizedQueue.new(2)
-    2.times { sq << 1 }
-
-    t1 = Thread.new do
-      sq << 1
-    end
-
-    t2 = Thread.new do
-      sq << 1
-    end
-
-    t3 = Thread.new do
-      Thread.pass
-      sq.clear
-    end
-
-    [t3, t2, t1].each(&:join)
-    assert_equal sq.length, 2
-  end
-
-  def test_sized_queue_throttle
-    q = SizedQueue.new(1)
-    i = 0
-    consumer = Thread.new do
-      while q.pop
-        i += 1
-        Thread.pass
-      end
-    end
-    nprod = 4
-    npush = 100
-
-    producer = nprod.times.map do
-      Thread.new do
-        npush.times { q.push(true) }
-      end
-    end
-    producer.each(&:join)
-    q.push(nil)
-    consumer.join
-    assert_equal(nprod * npush, i)
-  end
-
-  def test_queue_thread_raise
-    q = Queue.new
-    th1 = Thread.new do
-      begin
-        q.pop
-      rescue RuntimeError
-        sleep
-      end
-    end
-    th2 = Thread.new do
-      sleep 0.1
-      q.pop
-    end
-    sleep 0.1
-    th1.raise
-    sleep 0.1
-    q << :s
-    assert_nothing_raised(TimeoutError) do
-      timeout(1) { th2.join }
-    end
-  end
-end