code: def _process(self, metric):
          
          try:
              self.queue.put(metric, block=False)
          except Queue.Full:
              self._throttle_error('Queue full, check handlers for delays')
docs: We skip any locking code due to the fact that this is now a single
          process per collector