(self)
Create the initial mapping of processes and queues.

        :meta private:
Create the initial mapping of processes and queues.
Create the initial mapping of processes and queues .
def init(self) -> None:
        """
        Create the initial mapping of processes and queues.

        :meta private:
        """
        for _ in range(self.queue_count):
            tx = self.context.Queue()
            rx = self.context.Queue()
            qid = self.scheduler.register_queue(tx)

            self.queues[qid] = (tx, rx)

        qids = list(self.queues.keys())
        for i in range(self.process_count):
            qid = qids[i % self.queue_count]
            self.processes[self.create_worker(qid)] = qid
            self.scheduler.register_process(qid)
def init ( self ) -> None : for _ in range ( self . queue_count ) : tx = self . context . Queue ( ) rx = self . context . Queue ( ) qid = self . scheduler . register_queue ( tx ) self . queues [ qid ] = ( tx , rx ) qids = list ( self . queues . keys ( ) ) for i in range ( self . process_count ) : qid = qids [ i % self . queue_count ] self . processes [ self . create_worker ( qid ) ] = qid self . scheduler . register_process ( qid )