Sha256: 755f8e5461cd5cbf3ef6099f400309ddbacdfe4e0bd1be70c963deb17f9ece90
Contents?: true
Size: 1.98 KB
Versions: 29
Compression:
Stored size: 1.98 KB
Contents
# frozen_string_literal: true
require "concurrent/executor/thread_pool_executor"
require "concurrent/executor/immediate_executor"
require "concurrent/configuration"
module Sentry
class BackgroundWorker
include LoggingHelper
attr_reader :max_queue, :number_of_threads
# @deprecated Use Sentry.logger to retrieve the current logger instead.
attr_reader :logger
attr_accessor :shutdown_timeout
def initialize(configuration)
@max_queue = 30
@shutdown_timeout = 1
@number_of_threads = configuration.background_worker_threads
@logger = configuration.logger
@debug = configuration.debug
@shutdown_callback = nil
@executor =
if configuration.async
log_debug("config.async is set, BackgroundWorker is disabled")
Concurrent::ImmediateExecutor.new
elsif @number_of_threads == 0
log_debug("config.background_worker_threads is set to 0, all events will be sent synchronously")
Concurrent::ImmediateExecutor.new
else
log_debug("Initializing the background worker with #{@number_of_threads} threads")
executor = Concurrent::ThreadPoolExecutor.new(
min_threads: 0,
max_threads: @number_of_threads,
max_queue: @max_queue,
fallback_policy: :discard
)
@shutdown_callback = proc do
executor.shutdown
executor.wait_for_termination(@shutdown_timeout)
end
executor
end
end
# if you want to monkey-patch this method, please override `_perform` instead
def perform(&block)
@executor.post do
begin
_perform(&block)
rescue Exception => e
log_error("exception happened in background worker", e, debug: @debug)
end
end
end
def shutdown
log_debug("Shutting down background worker")
@shutdown_callback&.call
end
private
def _perform(&block)
block.call
end
end
end
Version data entries
29 entries across 29 versions & 2 rubygems