使用键盘中断停止在队列中工作的所有线程

import threading
import queue

# 创建一个队列
my_queue = queue.Queue()

# 创建一个线程类
class MyThread(threading.Thread):
    def __init__(self, queue):
        threading.Thread.__init__(self)
        self.queue = queue

    def run(self):
        while True:
            try:
                # 从队列中获取任务
                task = self.queue.get()
                # 执行任务
                print("Processing task:", task)
            except KeyboardInterrupt:
                # 接收到中断信号时停止线程
                print("Keyboard interrupt received. Stopping thread.")
                break

# 创建并启动多个线程
threads = []
for i in range(5):
    thread = MyThread(my_queue)
    thread.start()
    threads.append(thread)

# 向队列中添加任务
for i in range(10):
    my_queue.put(i)

# 等待所有线程完成任务
for thread in threads:
    thread.join()