initialize

in lib/aws/active_job/sqs/executor.rb [31:44]

• 12 lines of code
• 2 McCabe index (conditional complexity)

        def initialize(options = {})
          @executor = Concurrent::ThreadPoolExecutor.new(DEFAULTS.merge(options))
          @logger = options[:logger] || ActiveSupport::Logger.new($stdout)
          @task_complete = Concurrent::Event.new
          @post_mutex = Mutex.new

          @error_handler = options[:error_handler]
          @error_queue = Thread::Queue.new
          @error_handler_thread = Thread.new(&method(:handle_errors))
          @error_handler_thread.abort_on_exception = true
          @error_handler_thread.report_on_exception = false
          @shutting_down = Concurrent::AtomicBoolean.new(false)
        end