Contents

require "set"

module Celluloid
  module ClassMethods
    # Create a new pool of workers. Accepts the following options:
    #
    # * size: how many workers to create. Default is worker per CPU core
    # * args: array of arguments to pass when creating a worker
    #
    def pool(config={})
      Celluloid.services.supervise(config.merge(type: Supervision::Container::Pool, args: [{workers: self}]))
      Celluloid.services.actors.last
    end

    # Same as pool, but links to the pool manager
    def pool_link(klass, config={})
      Supervision::Container::Pool.new_link(
        config.merge(args: [{workers: klass}]),
      )
    end
  end

  module Supervision
    class Container
      def pool(klass, config={})
        Celluloid.services.supervise(config.merge(type: Container::Pool, args: [{workers: klass}]))
        Celluloid.services.actors.last
      end

      class Instance
        attr_accessor :pool, :pool_size
      end

      class << self
        # Register a pool of actors to be launched on group startup
        def pool(klass, *args, &_block)
          blocks << lambda do |container|
            container.pool(klass, Configuration.options(args))
          end
        end
      end

      class Pool
        include Behavior

        identifier! :size, :pool

        configuration do
          puts "configuring pool"
          @supervisor = Container::Pool
          @method = "pool_link"
          @pool = true
          @pool_size = @cofiguration[:size]
          @configuration
        end
      end

      
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
celluloid-pool-0.10.0.pre4	lib/celluloid/supervision/container/behavior/pool.rb