diff options
Diffstat (limited to 'test/thread')
| -rw-r--r-- | test/thread/test_queue.rb | 38 |
1 files changed, 0 insertions, 38 deletions
diff --git a/test/thread/test_queue.rb b/test/thread/test_queue.rb deleted file mode 100644 index b0ffe0866d..0000000000 --- a/test/thread/test_queue.rb +++ /dev/null @@ -1,38 +0,0 @@ -require 'test/unit' -require 'thread' - -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 -end |
