Contents

module Celluloid
  class Group
    class Manager
      include Celluloid

      def manage!(group)
        @group = group
        every(1.26) { garbage_collector }
      end

      def garbage_collector
        @group.each do |t|
          puts "running Group::Manager garbage_collector"
          #           case t[:celluloid_meta][:state]
          #           when :finished
          #             # puts "thread finished: #{t.inspect}"
          #           else
          #             # puts "thread state: #{t[:celluloid_meta]}"
          #           end
          #           # puts "thread: #{t[:celluloid_actor].name}"
        end
      rescue => ex
        puts "#{ex.backtrace.first}"
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
celluloid-0.17.0	lib/celluloid/group/manager.rb