4
5
6
7
8
9
10
11
12
13
|
# File 'lib/filbunke/callbacks.rb', line 4
def initialize(logger, config = {})
@config = config
@logger = logger
num_callback_threads = @config["num_callback_threads"].to_i
num_callback_processes = @config["num_callback_processes"].to_i
if num_callback_threads == 0 and num_callback_processes == 0
@config["num_callback_threads"] = Parallel.processor_count
end
@parallel_callback_opts = (num_callback_threads > 0 ? {:in_threads => num_callback_threads} : {:in_processes => num_callback_processes})
end
|