python - Python - 这个线程/循环/等待代码是否不好

问题描述

我有一个 python 应用程序，其中 thread1 调用一个 api 来查看“准备下载哪些报告”并将该 report_id 发送到 thread2，后者“下载/处理这些报告”。这些线程遍历字典，然后等待 5 分钟。即使代码“什么都不做”，它也与 CPU 挂钩。

我不确定 CPU 是挂在线程中还是主线程中。在 main 中，我有一些处理程序来检查停止信号，所以我发布了大部分代码。我有几个线程以类似的方式执行类似的任务，它们在循环结束时等待。我怀疑代码与 cpu 挂钩的领域 a) 在 main - while run: pass. b）在每个线程is_killed = self._kill.wait(600)中，这是一个theading.Event()

知道什么是挂cpu。

if __name__ == '__main__':

t2 = ProcessReport()
t2.start()

t1 = RequestReport(t2)
t1.start()

t3 = report_test()
t3.start()

t4 = run_flask()
t4.start()

run = True
signal.signal(signal.SIGINT, handler_stop_signals)
signal.signal(signal.SIGTERM, handler_stop_signals)
signal.signal(signal.SIGHUP, handler_stop_signals)

while run:
    pass  # Stay here until kill

print("About to kill all threads in clean order")
t3.kill()
t3.join()  
t1.kill()
t1.join() 
t2.kill()
t2.join()
print("Clean Exit")
sys.exit()

信号处理器

def handler_stop_signals(signum, frame):
    global run
    run = False

线程之一

class report_test(Thread):
  def __init__(self):
    Thread.__init__(self)
    self._kill = threading.Event()

def kill(self):
    self._kill.set()

def run(self):

    while True:
        cursor.execute("SELECT * FROM tbl_rpt_log where cron='1'")
        reports_to_run = cursor.fetchall()

        for row in reports_to_run:
            report_on_row(row)

        is_killed = self._kill.wait(600)
        if is_killed:
            print("Killing - ReportCheckTable")
            break

标签： pythonmultithreadingcpupython-multithreading

问题（至少是主要问题）是：

while run:
    pass  # Stay here until kill

这是因为这里唯一的操作是评估循环的条件，而CPU “无法捕捉中断”。

我没有仔细阅读整个代码来理解它的高层次，但解决它的最快方法是：

import time

# ...

while run:
    time.sleep(0.1)  # Stay here until kill

python - Python - 这个线程/循环/等待代码是否不好 - 它“钉住”cpu

问题描述

解决方案

推荐阅读