(self, qid: QueueID)
return process
Create a worker process attached to the given transmit and receive queues.

        :meta private:
Create a worker process attached to the given transmit and receive queues.
Create a worker process attached to the given transmit and receive queues .
def create_worker(self, qid: QueueID) -> Process:
        """
        Create a worker process attached to the given transmit and receive queues.

        :meta private:
        """
        tx, rx = self.queues[qid]
        process = PoolWorker(
            tx,
            rx,
            self.maxtasksperchild,
            self.childconcurrency,
            initializer=self.initializer,
            initargs=self.initargs,
            loop_initializer=self.loop_initializer,
            exception_handler=self.exception_handler,
        )
        process.start()
        return process
def create_worker ( self , qid : QueueID ) -> Process : tx , rx = self . queues [ qid ] process = PoolWorker ( tx , rx , self . maxtasksperchild , self . childconcurrency , initializer = self . initializer , initargs = self . initargs , loop_initializer = self . loop_initializer , exception_handler = self . exception_handler , ) process . start ( ) return process