مقایسه‌ی الگوهای ارکستراسیون

sub_questions = self.plan(query)               # 3 زیرسوال
results: list[WorkerResult | None] = [None] * len(sub_questions)
threads: list[threading.Thread] = []
for i, sq in enumerate(sub_questions):
    w = Worker(worker_id=i, trace=self.trace)  # کارگر تازه به ازای هر زیرسوال
    th = threading.Thread(target=w.run, args=(sq, results, i))
    threads.append(th)
    th.start()                                 # اجرای هم‌زمان تمام کارگران
for th in threads:
    th.join()                                  # زمان واقعی نزدیک به بیشینه است، نه مجموع
synthesis = self.synthesize(query, [r for r in results if r is not None])

q: queue.Queue = queue.Queue()
for t in tasks:
    q.put(t)                  # هیچ هماهنگ‌کننده‌ای کار اختصاص نمی‌دهد
def worker(wid: int) -> None:
    while True:
        try:
            task = q.get_nowait()
        except queue.Empty:
            return            # تخلیه صف، خروج کارگر
        fake_work(task)
        with lock:
            counts[wid] += 1  # کارگران سریع کارهای بیشتری می‌کشند
        q.task_done()