Python 脚本死锁问题与解决方案

import queue
import threading
import signal
import subprocess
# 创建一个队列来存储子进程的输出
output_queue = queue.Queue()
# 创建一个函数来处理子进程的输出
def process_output(output):
    # 在这里处理子进程的输出
    # ...
# 创建一个函数来启动一个子进程
def start_subprocess(command):
    # 启动一个子进程
    process = subprocess.Popen(command, stdout=subprocess.PIPE)
    # 将子进程的输出添加到队列中
    for line in iter(process.stdout.readline, b''):
        output_queue.put(line.decode('utf-8'))
    # 等待子进程完成
    process.wait()
# 创建一个函数来处理 Ctrl+C 中断信号
def signal_handler(signal, frame):
    # 关闭所有子进程
    for thread in threads:
        thread.join()
    # 退出脚本
    exit()
# 注册 Ctrl+C 中断信号处理函数
signal.signal(signal.SIGINT, signal_handler)
# 创建一个列表来存储线程
threads = []
# 启动一定数量的线程来启动子进程
for i in range(10):
    thread = threading.Thread(target=start_subprocess, args=('python script.py',))
    threads.append(thread)
    thread.start()
# 从队列中读取输出并进行处理
while True:
    output = output_queue.get()
    process_output(output)