code: def _start_thread(self):
          
          self._stopping_event = Event()
          self._enqueueing_thread = Thread(target=self._enqueue_batches, args=(self._stopping_event,))
          self._enqueueing_thread.start()
docs: Start an enqueueing thread.