调度的操作到达操作创建者，而不是接收者

import queue
import threading

# 定义一个任务类
class Task:
    def __init__(self, task_id, receiver):
        self.task_id = task_id
        self.receiver = receiver

# 定义一个调度器
class Scheduler:
    def __init__(self):
        self.task_queue = queue.Queue()

    def add_task(self, task):
        self.task_queue.put(task)

    def run(self):
        while not self.task_queue.empty():
            task = self.task_queue.get()
            if task.receiver == "receiver":
                print(f"Task {task.task_id} sent to receiver")
            else:
                print(f"Task {task.task_id} sent to creator")

# 创建任务并添加到调度器
scheduler = Scheduler()
task1 = Task(1, "receiver")
task2 = Task(2, "creator")
scheduler.add_task(task1)
scheduler.add_task(task2)

# 启动调度器
scheduler_thread = threading.Thread(target=scheduler.run)
scheduler_thread.start()
scheduler_thread.join()