process.py 文件源码

def make_server_manager(port, authorization_key):
    """ Create a manager for the server, listening on the given port.

        Return a manager object with get_job_q and get_result_q
        methods.

        Arguments:
        port -- Port to use for communication
        authorization_key -- program secret used to identify correct server

        Returns:
        Manager to process jobs
    """

    job_queue = Queue()
    result_queue = Queue()

    class JobQueueManager(multiprocessing.managers.SyncManager):
        pass

    JobQueueManager.register(JOB_QUEUE_NAME, callable=lambda: job_queue)
    JobQueueManager.register(RES_QUEUE_NAME, callable=lambda: result_queue)

    manager = JobQueueManager(address=('', port), authkey=authorization_key)

    return manager