1

我不明白为什么下面的代码块。我试图简单地循环一段时间，然后向线程发送一条消息以停止。我的流程类如下。

class Worker(multiprocessing.Process):
    def __init__(self, queue):
        multiprocessing.Process.__init__(self)
        self.queue = queue
        self.running = True

    def run(self):
        print 'entered run'
        while self.running:
            print 'thread time:', time.time()
            time.sleep(.6)
        print 'thread end'
        return 0

很直接。我的主要看起来像这样：

if __name__ == '__main__':
    queue = Queue()
    p = Worker(queue)
    p.daemon = True
    p.start()
    time.sleep(3)
    p.running = False
    print 'Main end'

所以，我期望这个程序做的是启动一个进程，该进程将在 main 的一侧运行它自己的循环。发生这种情况时，Main()将休眠 3 秒，然后将工作进程内部的循环条件设置为 False，以便它跳出循环。然后他们都打印一个很好的“完成”消息，程序退出。但是，问题是main线程在进程有机会显示其消息之前就退出了。

例如，输出如下所示：

>> entered run
>> thread time: 1358444245.31
>> thread time: 1358444245.91
>> thread time: 1358444246.51
>> thread time: 1358444247.11
>> thread time: 1358444247.71
>> Main end

所以，读了一点，我发现这join()是用来阻塞的，直到线程完成执行。join()在此之后，我在打破线程中的循环条件后立即添加一个调用。我的想法是，这将阻塞 main ，直到进程有时间自行关闭。

if __name__ == '__main__':
    queue = Queue()
    p = Worker(queue)
    p.daemon = True
    p.start()
    time.sleep(3)
    p.running = False
    p.join()          ## <------ New Line 
    print 'Main end'

但是，这种行为出乎意料。一旦我添加了该行，线程就永远不会停止执行，因此 main 会无限期地阻塞。下面的输出将旋转到永恒。

>> entered run
>> thread time: 1358444362.44
>> thread time: 1358444363.04
>> thread time: 1358444363.64
>> thread time: 1358444364.24
>> thread time: 1358444364.84
>> thread time: 1358444365.44
>> thread time: 1358444366.04
>> thread time: 1358444366.64
>> thread time: 1358444367.24
>> thread time: 1358444367.84
>> thread time: 1358444368.44
>> thread time: 1358444369.04
>> thread time: 1358444369.64
>> thread time: 1358444370.24

这里发生了什么？为什么当我添加时join()我的线程没有跳出它的循环？

4

1 回答 1

2

首先，multiprocessing.Process不创建 a Thread，它创建一个单独的进程来执行提供的函数。

您将需要用于multiprocessing.Queue在 2 个进程之间传递消息。

看看：http ://docs.python.org/2/library/multiprocessing.html#exchanging-objects-between-processes

正如 Max Yakimets 所提到的，您正在第一个进程中修改值，但从未将消息传递给第二个进程。

p.running您需要在队列中添加一个项目，而不是更改该值。在此过程中，您需要检查队列中是否有任何消息在等待并对其做出反应（关闭、执行其他操作等）

于 2013-01-17T18:30:38.863 回答