class WoolenCommon::ActionPoolProxy

Constants

MAX_THREAD

Public Class Methods

get_pool() click to toggle source
# File lib/woolen_common/action_pool_proxy.rb, line 13
def get_pool
    @action_pool ||= ::ActionPool::Pool.new(:min_thread => 1, :max_thread => MAX_THREAD)
end
process(*args,&block) click to toggle source
# File lib/woolen_common/action_pool_proxy.rb, line 17
def process(*args,&block)
    trace "invoke the action pool process,args:#{args}"
    begin
        self.get_pool.process(*args,&block)
    rescue Exception => e
        error "we get the invoke process error::#{e.message}",e
    end
end