module ActiveSupport::LoggerThreadSafeLevel

def after_initialize
  @local_levels = Concurrent::Map.new(initial_capacity: 2)
end

def level
  local_level || super
end

def local_level
  @local_levels[local_log_id]
end

def local_level=(level)
  if level
    @local_levels[local_log_id] = level
  else
    @local_levels.delete(local_log_id)
  end
end

def local_log_id
  Thread.current.__id__
end