

def _prepare_queue(self):
    " Replaces the trajectory's service with a queue sender and starts the queue process.\n\n        "
    if (self._queue is None):
        if self._use_manager:
            if (self._manager is None):
                self._manager = multip.Manager()
            self._queue = self._manager.Queue(maxsize=self._queue_maxsize)
        else:
            self._queue = multip.Queue(maxsize=self._queue_maxsize)
    self._logger.info('Starting the Storage Queue!')
    queue_handler = QueueStorageServiceWriter(queue_handler._storage_service, self._queue, self._gc_interval)
    self._queue_process = multip.Process(name='QueueProcess', target=_wrap_handling, args=(dict(handler=queue_handler, logging_manager=self._logging_manager, graceful_exit=self._graceful_exit),))
    self._queue_process.start()
    self._queue_wrapper = QueueStorageServiceSender(self._queue)
    self._traj.v_storage_service = self._queue_wrapper

dataset/ETHPy150Open SmokinCaterpillar/pypet/pypet/environment.py MultiprocContext._prepare_queue/VarMisuse@104/174 `self`->`queue_handler`