thread_with_connection.rb

PassthroughExceptions = [
  ::NoMemoryError,
  ::SignalException,
  ::Interrupt,
  ::SystemExit,
]

def Thread.with_connection(*args)
  start(*args) do |*inner_args|
    begin
      yield(*inner_args)
    rescue *PassthroughExceptions
      raise # do not handle PassthroughExceptions ourselves
    rescue Exception => exception
      ExceptionHandler.handle(exception)
    ensure
      ActiveRecord::Base.clear_active_connections!
    end
  end
end