Contents

# frozen_string_literal: true

module DatadogBackup
  module ThreadPool
    TPOOL = ::Concurrent::ThreadPoolExecutor.new(
      min_threads: [2, Concurrent.processor_count].max,
      max_threads: [2, Concurrent.processor_count].max * 2,
      fallback_policy: :abort
    )

    def self.watcher
      Thread.new(TPOOL) do |pool|
        while pool.queue_length.positive?
          sleep 2
          LOGGER.info("#{pool.queue_length} tasks remaining for execution.")
        end
      end
    end

    def self.shutdown
      LOGGER.fatal 'Shutdown signal caught. Performing orderly shut down of thread pool. Press Ctrl+C again to forcibly shut down, but be warned, DATA LOSS MAY OCCUR.'
      TPOOL.shutdown
      TPOOL.wait_for_termination
    rescue SystemExit, Interrupt
      LOGGER.fatal 'OK Nuking, DATA LOSS MAY OCCUR.'
      TPOOL.kill
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
datadog_backup-3.0.0	lib/datadog_backup/thread_pool.rb
datadog_backup-3.0.0.alpha.2	lib/datadog_backup/thread_pool.rb
datadog_backup-3.0.0.alpha.1	lib/datadog_backup/thread_pool.rb
datadog_backup-2.0.2	lib/datadog_backup/thread_pool.rb