code: def _worker_thread_transfer(self):
          # type: (Uploader) -> None
          
          while not self.termination_check:
              try:
                  ud, ase, offsets, data = self._transfer_queue.get(
                      block=False, timeout=0.1)
              except queue.Empty:
                  continue
              try:
                  self._process_transfer(ud, ase, offsets, data)
              except Exception as e:
                  with self._upload_lock:
                      self._exceptions.append(e)
docs: Worker thread transfer
          :param Uploader self: this