在守护进程中运行线程+队列

Question

我已经在 Python 文件 myfile.py 中成功实现了线程 + 队列。现在我希望这个文件作为守护进程运行，因为当所有线程都完成了它们的任务时，我想重新填充队列并让线程处理新任务。我在这里尝试了一些代码，但程序没有正确响应：

# myfile.py

threadList = list()
i = 0
while i < 10:
    i += 1
    threadName = "T" + str(i)
    threadList.append(threadName)

#create queue
myQueue = Queue.Queue();

# create thread objects
threads = list()
for threadName in threadList:
    thread = WorkerThread(threadName, myQueue)
    thread.start()
    threads.append(thread)

def hello():    
    while True:
        logger.debug("true")
        if myQueue.empty():
            logger.debug("empty")
        else:
            logger.debug("not empty")

def run():
    daemon_context = daemon.DaemonContext(files_preserve=[handler.stream],
                                          stdout = open("./stdout.log","wb"),
                                          stderr = open("./stderr.log","wb"))
    with daemon_context:
        hello()

if __name__ == "__main__":
    run()

当脚本执行时，它会打印“true”并停在那里。它不会记录“空”或“非空”。终端和 stderr.log 中没有显示错误。但是，如果我删除myQueue.empty() 的条件检查，守护程序将继续打印“true”。为什么队列在守护进程中不起作用？

Answer 1

我怀疑您会看到这种奇怪的行为，因为您在守护进程之前运行了一堆代码，这在内部执行 os.fork()。这让您处于一种奇怪的状态，您的一些代码在一个进程中开始，但随后您分叉（意味着您获得了一个新进程）并开始尝试使用您在分叉之前创建的那些对象，这将无法正常工作.例如，所有正在运行的线程都会被杀死。您需要将所有您的代码移到with daemon_context 块内，才能开始工作。

不过，我会小心的。您正在使用 while True 循环快速将大量内容写入磁盘。