[ruby-dev:44400] [Ruby 1.9 - Bug #5195][Open] Queue#popでsleepしているthreadをwakeupさせるとQueueの@waitingにそのthreadがpushされてしまう

Issue #5195 has been reported by Masaki Matsushita.

----------------------------------------
Bug #5195: Queue#popでsleepしているthreadをwakeupさせるとQueueの@waitingにそのthreadがpushされてしまう
http://redmine.ruby-lang.org/issues/5195

Author: Masaki Matsushita
Status: Open
Priority: Normal
Assignee: 
Category: lib
Target version: 1.9.x
ruby -v: ruby 1.9.4dev (2011-08-14 trunk 32972) [x86_64-linux]


=begin
次のようなコードを実行すると、
 
 require 'thread'
 
 queue = Queue.new
 
 t1 = Thread.start { queue.pop; p 1 }
 
 nil until t1.stop?
 t1.wakeup
 nil until t1.stop?
 
 t2 = Thread.start { queue.pop; p 2 }
 
 nil until t1.stop? && t2.stop?
 
 p t1, t2
 queue.instance_eval{ p @waiting }
 
 2.times{ queue.push(nil) }
 
 t1.join
 t2.join

以下のような結果となります。

 #<Thread:0x000000014d8108 sleep>
 #<Thread:0x000000014d8090 sleep>
 [#<Thread:0x000000014d8108 sleep>, #<Thread:0x000000014d8108 sleep>, #<Thread:0x000000014d8090 sleep>]
 1
 /home/masaki/ruby/queue_waiting.rb:22:in `join': deadlock detected (fatal)
 from /home/masaki/ruby/queue_waiting.rb:22:in `<main>'

lib/thread.rbの184行目でQueue#popが以下のように定義されていますが、

 def pop(non_block=false)
    @mutex.synchronize{
      while true
        if @que.empty?
          raise ThreadError, "queue empty" if non_block
          @waiting.push Thread.current
          @mutex.sleep
        else
          return @que.shift
        end
      end
    }
  end

このコードではQueue#popでsleepしているthreadをwakeupさせると、既にpush済みのThread.currentが再度@waitingにpushされてしまいます。
これはバグではないでしょうか。

patchを添付します。
このpatchでは遅くなってしまうのではないかと懸念しましたが、

 require 'benchmark'
 require 'thread'
 
 def push_pop
   q = Queue.new
   time = 100000
 
   push = Thread.start do
     time.times { q.push(nil) }
   end
 
   pop = Thread.start do
     time.times { q.pop }
   end
 
   push.join
   pop.join
 end
 
 Benchmark.bm do |x|
   x.report("before") { push_pop }
 end

というベンチマークを作って試してみたところ、
patchの適用以前が

 user     system      total        real
 0.460000   0.000000   0.460000 (  0.452595)
 0.500000   0.040000   0.540000 (  0.529834)
 0.410000   0.030000   0.440000 (  0.433928)

適用後が

 user     system      total        real
 0.480000   0.060000   0.540000 (  0.505939)
 0.450000   0.000000   0.450000 (  0.449451)
 0.430000   0.010000   0.440000 (  0.435586)

となったのでそれほどには遅くなっていないようです。
patchの適用後もtest/thread/test_queue.rbをパスします。

=end


-- 
http://redmine.ruby-lang.org