kernel/core/thread_group.rb

   1 # depends on: class.rb
   2
   3 class ThreadGroup
   4   def initialize
   5     @threads = []
   6   end
   7
   8   def add(thread)
   9     if thread.group
  10       thread.group.remove(thread)
  11     end
  12     thread.add_to_group self
  13     @threads << WeakRef.new(thread)
  14     self
  15   end
  16
  17   def prune
  18     @threads.delete_if { |w| !w.weakref_alive? or !w.object.alive? }
  19   end
  20
  21   private :prune
  22
  23   def remove(thread)
  24     prune
  25     @threads.delete_if { |w| w.object == thread }
  26   end
  27
  28   def list
  29     prune
  30     @threads.map { |w| w.object }
  31   end
  32
  33   def list_all
  34     @threads.delete_if { |w| !w.weakref_alive? }
  35     @threads.map { |w| w.object }
  36   end
  37
  38 end