code: def run(self):
          
          self.collector.start()
          if self.standalone:
              self.collector.join()
docs: Start the collector worker thread.
  
          If running in standalone mode, the current thread will wait
          until the collector thread ends.