[ruby-dev:28196] Re: test_each(TC_SyncEnumerator) fails.

山本です。

>>> とあったので試しに Mutex で実装してみたのですが、これで直ったりしますか？
>>
>>症状は消えました。
>>
>>コードは読んでないんで正しいかどうかはわかりませんが。
>
>私も正しいかどうか自信がありません（汗）とりあえずコミットしますが、
>おかしいところがありましたら直してください。

すみません、こんなスクリプトを書いたらすぐに再現しました。

require "generator"

def assert_equal(x, y)
  raise "error" unless x == y
end

loop do

  r = ['a'..'f', 1..10, 10..20]
  ra = r.map { |x| x.to_a }
  a = (0...(ra.map {|x| x.size}.max)).map { |i| ra.map { |x| x[i] } }

  s = SyncEnumerator.new(*r)

  i = 0
  s.each { |x|
    assert_equal(a[i], x)
    i += 1
    break if i == 3
  }

  assert_equal(3, i)

  i = 0
  s.each { |x|
    assert_equal(a[i], x)
    i += 1
  }

  assert_equal(a.size, i)

end

それでスタックトレースを見て、rewind が呼ばれているのを見てわかりました。

Index: lib/generator.rb
===================================================================
RCS file: /src/ruby/lib/generator.rb,v
retrieving revision 1.11
diff -u -p -r1.11 generator.rb
--- lib/generator.rb	30 Dec 2005 10:17:39 -0000	1.11
+++ lib/generator.rb	31 Dec 2005 02:35:47 -0000
@@ -152,7 +152,10 @@ class Generator
 
   # Rewinds the generator.
   def rewind
-    initialize(nil, &@block) if @index.nonzero?
+    if @index.nonzero? # needed?
+      @loop_thread.kill
+      initialize(nil, &@block)
+    end
     self
   end
 
---
 
GC とか、前のほうのメソッドばかり見ていて、rewind は盲点でした。
修正しておきます。