如何在python中的多处理器之间进行竞赛

您可以使用multiprocessing.Pool及其方法map()、imap_unordered()等.这些方法还将从辅助函数返回值.

例如(我用time.sleep()来模拟一些时间计算):

from time import sleep
from multiprocessing import Pool


def rho(params):
    n, processor = params
    # your computation here
    # ...
    sleep(n)
    print("Factor was found from " + processor + " and is 42")
    return 42


if __name__ == "__main__":
    with Pool() as pool:
        for result in pool.imap_unordered(
            rho, ((10, "process 1"), (1, "process 2"))
        ):
            print("Result I got:", result)
            break  # <-- I don't want other results, so break

输出:

Factor was found from process 2 and is 42
Result I got: 42

编辑:两个不同的功能:

from time import sleep
from multiprocessing import Pool


def fn1(n, p):
    sleep(n)
    print("Factor was found from " + p + " and is 42")
    return 42


def fn2(n, p):
    sleep(n)
    print("Factor was found from " + p + " and is 99")
    return 99


def rho(params):
    what_to_call, n, processor = params
    return what_to_call(n, processor)


if __name__ == "__main__":
    with Pool() as pool:
        for result in pool.imap_unordered(
            rho, ((fn1, 10, "process 1"), (fn2, 1, "process 2"))
        ):
            print("Result I got:", result)
            break  # <-- I don't want other results, so break