'Get queues for a new process.
Here we\'ll find an unused slot, as there should always
be one available when we start a new process.'

def get_process_queues(self):

    return next((q for (q, owner) in items(self._queues) if (owner is None)))
