处理多处理和睡眠的推荐方法是什么？

Question

所以，这几天我一直在玩 Python 的 multiprocessing 模块，但有些东西我无法理解。也许有人可以给我一点帮助。

我正在尝试从同一类并行运行两个方法，但显然我缺少一些东西：

from multiprocessing import Process
import time


class SomeClass:
    def __init__(self):
        pass

    def meth1(self):
        print(1)
        time.sleep(10)

    def meth2(self):
        print(2)
        time.sleep(5 * 60)


def main():
    while True:
        s = SomeClass()

        p1 = Process(target=s.meth1)  # I want this to run from 10 to 10 seconds
        p1.start()
        p2 = Process(target=s.meth2)  # I want this to run from 5 to 5 minutes
                                      # while the first one still does its own
                                      # job from 10s to 10s
        p2.start()

        p1.join()
        p2.join()


if __name__ == '__main__':
    main()

我期望发生的是：

• 第一种方法应该打印1;
• 然后第二个应该打印2（无需等待 10 秒 - 这确实发生并且似乎按预期工作）；
• 那么我应该在接下来的 4 分钟和 50 秒内只看到 1 秒（这不会发生，程序只是等待那个时间过去。

我错过了什么？为什么第二步按预期工作，但第三步没有？我怎样才能让它发挥作用？

Answer 1

很难真正知道你想要什么，但下面的代码做了你描述的，但没有方便的退出方式：

from multiprocessing import Process
import time


class SomeClass:
    def __init__(self):
        pass

    def meth1(self):
        while True:
            print(1)
            time.sleep(10)


    def meth2(self):
        while True:
            print(2)
            time.sleep(5 * 60)


def main():
    s = SomeClass()

    p1 = Process(target=s.meth1)  # I want this to run from 10 to 10 seconds
    p1.start()
    p2 = Process(target=s.meth2)  # I want this to run from 5 to 5 minutes while the first one still does its own job from 10s to 10s
    p2.start()

    p1.join()
    p2.join()



if __name__ == '__main__':
    main()

我已将while 移动到SomeClass 的每个方法中

这段代码永远不会退出，挂在p1.join()

Answer 2

将流程视为您的朋友/克隆，您可以通过电话呼叫它们，进来做某事，然后当它们都完成后，它们就回家了，给您留下一个便条。

线条：

p1 = Process(target=s.meth1)
p1.start()

呼叫一个克隆并让他运行s.meth1。他走过来，在你的屏幕上打印 1，等待 10 秒，然后给你留下一张便条：“全部完成，没有异常发生，我已经回家了”。

同时（当你的第一个克隆即将到来时），这些行：

p2 = Process(target=s.meth2)
p2.start()

呼叫另一个克隆并让他运行s.meth2。他过来，在你的屏幕上打印 2，等了大约 5 分钟，然后给你留了一张纸条：“全部完成，没有发生异常，我已经回家了”。

当克隆 #1 和 #2 正在工作时，行：

p1.join()

等待克隆 #1 给你留下他的笔记。这发生在 10 秒后。然后你继续：

p2.join()

它等待克隆 #2 给你留下他的笔记。这会在另外 4 分 50 秒后发生。然后你回到你的while True 重新开始一切。

如果您希望不等待克隆 #2 完成并给您留下他的笔记，请不要致电 p2.join()。不过，最终，您应该致电p2.join()，以确保一切顺利并且他成功回家，并且没有死在你客厅的血泊中，被某些人射杀例外。 :-)