Sha256: 63a57961e6300bf0a9230c3f8a12fa471d73ba66e6daa8f2cc16e447c29b937e
Contents?: true
Size: 1.17 KB
Versions: 9
Compression:
Stored size: 1.17 KB
Contents
require "concurrent/executor/thread_pool_executor"
require "concurrent/executor/immediate_executor"
module Sentry
class BackgroundWorker
attr_reader :max_queue, :number_of_threads
def initialize(configuration)
@max_queue = 30
@number_of_threads = configuration.background_worker_threads
@executor =
if configuration.async
configuration.logger.debug(LOGGER_PROGNAME) { "config.async is set, BackgroundWorker is disabled" }
Concurrent::ImmediateExecutor.new
elsif @number_of_threads == 0
configuration.logger.debug(LOGGER_PROGNAME) { "config.background_worker_threads is set to 0, all events will be sent synchronously" }
Concurrent::ImmediateExecutor.new
else
configuration.logger.debug(LOGGER_PROGNAME) { "initialized a background worker with #{@number_of_threads} threads" }
Concurrent::ThreadPoolExecutor.new(
min_threads: 0,
max_threads: @number_of_threads,
max_queue: @max_queue,
fallback_policy: :discard
)
end
end
def perform(&block)
@executor.post do
block.call
end
end
end
end
Version data entries
9 entries across 9 versions & 2 rubygems