[ruby-list:25260] Re: priority & ThreadGroup (Re: [ruby-dev:9438] Re: $SAFE)

咳といいます。

matz> Ruby 1.5ではスレッドのpriorityとThreadGroupによってその問題
matz> に対処しようとしています。つまり、agentなスレッドのプライオ
matz> リティを下げたり、スレッドグループ全体をkillしたりしようと言
matz> うわけです。

咳>= priority
咳> * safe_level が 4 のスレッドからは priority を参照、変更できない。

咳>= ThreadGroup
咳> * safe_level が 4 のスレッドからは ThreadGroup#add できない。


agentなスレッドとは $SAFE == 4 なスレッドということですね。

というわけで、$SAFE = 4 なスレッドを起こして停める、ThreadGroup を
使ったクラスを書いてみました。

killの仕方が難しい。

---- t4.rb ----
require 'thread'

class T4Thread
  def initialize(prio=nil, timer = nil, &block)
    @grp = ThreadGroup.new
    keeper(timer) if timer
    @thread = runner(prio, block)
  end
  attr_reader :thread

  def kill
    Thread.exclusive do
      @grp.list.each do |th|
	th.kill
      end
    end
  end

  def kill2
    list = @grp.list
    while list.size > 0
      list.each do |th|
	th.kill
      end
      list = @grp.list
    end
  end
  
  private
  def runner(prio, block)
    Thread.new do
      @grp.add Thread.current
      Thread.current.priority = prio if prio
      $SAFE = 4
      block.call
    end
  end

  def keeper(sec)
    Thread.new do
      sleep sec
      kill
    end
  end
end

if __FILE__ == $0
  after = ARGV.shift
  after = after.to_f if after

  $q = Queue.new
  
  def test_thread(n, gen=1)
    for i in (0..n)
      sleep 0.6
      $q.push([gen, i])
      Thread.new do
	test_thread(i, gen+1)
      end
    end
  end
  
  prio = Thread.current.priority - 1

  t4 = T4Thread.new(prio, after) do 
    test_thread(10)
  end
  
  Thread.new do
    while true
      p $q.pop
    end
  end

  unless after
    sleep 5
    t4.kill
  end

  t4.thread.join
  puts 'done'
  sleep 1
end