进程内线程的queue.Queue()或multiprocessing.Queue()

Question

假设我有3个进程：

在进程A中，有一个无限循环，它对self.marker做一些事情。但与此同时，self.marker也需要每1分钟更新一次，因此需要实现一个threading.Timer来完成此操作。

此计时器将在进程A中作为单独的线程运行，如下所示：

class A(Process):
    def _init__(self):
        self.marker = True
        self.q = Queue()

    def run(self):
        threading.Timer(60, updater).start()

        while True:
            if not self.q.empty():
                item = self.q.get()
                self.marker = item

            print(self.marker)

    def updater(self):
        self.q.put(not self.marker)
        threading.Timer(60, updater).start()

class B(Process):
    def _init__(self):

    def run(self):

class C(Process):
    def _init__(self):

    def run(self):

a = A()
b = B()
c = C()
a.start()
b.start()
c.start()

我的问题是：

1)在这段代码中，是否可以通过使用队列安全地更新self.marker？或者队列是不必要的

2) self.q应该是queue.Queue()还是multiprocessing.Queue

Answer 1

你第一个问题的答案是:不完全是。定时器创建辅助线程，因此进程A实际上有两个线程。函数updater在辅助(计时器)线程中运行，而run函数在主线程中执行。updater访问self.marker的值，而run设置相同的变量，这可能是竞争条件。如果您对队列所做的唯一事情就是处理这些计时器事件，那就没问题了。但是，如果有其他代码写入队列，您可能会遇到问题:在updater中的put语句和run中的get语句之间，self.marker可能会发生变化。

第二个问题的答案从你的帖子中看不清楚。thread.Queue()只是将相同的python对象从队列的一端移动到另一端。multiprocessing.Queue()在输入端对对象进行pickles，并对输出执行unpickle，从而重新创建对象并允许跨进程共享该对象。(对象不在进程之间共享，但它们在线程之间共享。)

顺便说一句，你可能应该把一个time.sleep()放到run中，否则你的打印语句将会给你带来大量的输出。