Method: JRubyParallelProcessing::DataProcessor#initialize

Defined in:
lib/jruby_parallel_processing/data_processor.rb

#initialize(data_array: nil, stream: nil, in_threads: 4, chunk_size: nil, logger: nil, queue_size: 100, timeout: 10) ⇒ DataProcessor

Returns a new instance of DataProcessor.



7
8
9
10
11
12
13
14
15
16
 
# File 'lib/jruby_parallel_processing/data_processor.rb', line 7

def initialize(data_array: nil, stream: nil, in_threads: 4, chunk_size: nil, logger: nil, queue_size: 100, timeout: 10)
  @data_array = data_array
  @stream = stream
  @in_threads = in_threads
  @chunk_size = chunk_size || (@data_array.size.to_f / in_threads).ceil if @data_array
  @logger = logger || Logger.new(STDOUT)
  @queue_size = queue_size
  @timeout = timeout
  @middlewares = { before_process: [], after_process: [] }
end