如何实现A、B、C三个for循环迭代完成后依次触发且并行运行？

核心思路是用生产者-消费者模式配合异步线程，让三个循环各自独立运行，同时通过队列传递索引来保证触发顺序和索引关系：

• A作为生产者，每完成一次迭代就把当前索引传递给B，无需等待B执行完成即可继续下一次迭代
• B消费A传递的索引，处理后再把自己的索引传递给C，同样无需等待C执行完成
• C消费B传递的索引执行逻辑

Python 实现示例 #

import threading
import queue

# 用于传递索引的线程安全队列
queue_a_to_b = queue.Queue()
queue_b_to_c = queue.Queue()

def loop_a(max_iter):
    for idx in range(max_iter):
        print(f"A迭代: 索引 {idx}")
        # 将当前索引发送给B
        queue_a_to_b.put(idx)
        # 这里添加A的业务逻辑

def loop_b():
    while True:
        # 从A的队列获取索引，计算B的索引（A索引-1）
        a_idx = queue_a_to_b.get()
        b_idx = a_idx - 1
        print(f"B迭代: 索引 {b_idx}")
        # 将B的索引发送给C
        queue_b_to_c.put(b_idx)
        # 标记当前任务完成，用于后续等待所有任务结束
        queue_a_to_b.task_done()
        # 这里添加B的业务逻辑

def loop_c():
    while True:
        # 从B的队列获取索引，计算C的索引（B索引-1 = A索引-2）
        b_idx = queue_b_to_c.get()
        c_idx = b_idx - 1
        print(f"C迭代: 索引 {c_idx}")
        queue_b_to_c.task_done()
        # 这里添加C的业务逻辑

if __name__ == "__main__":
    total_iterations = 5
    # 启动B和C的守护线程，主线程结束时自动退出
    threading.Thread(target=loop_b, daemon=True).start()
    threading.Thread(target=loop_c, daemon=True).start()
    # 运行A循环
    loop_a(total_iterations)
    # 等待所有队列中的任务处理完成
    queue_a_to_b.join()
    queue_b_to_c.join()
    print("所有迭代执行完毕")

关键说明 #

1. 线程与队列：使用threading.Thread让B和C异步运行，queue.Queue保证索引传递的线程安全性，避免竞态条件
2. 无等待逻辑：A在放入索引到队列后立刻继续下一次迭代，B和C同理，处理完当前索引后立刻等待下一个，完全不阻塞上游循环
3. 索引关系：B的索引始终是A的索引减1，C的索引始终是A的索引减2，严格符合需求
4. 优雅退出：通过daemon=True设置守护线程，配合queue.join()等待所有任务完成后，主线程可以正常退出

扩展注意事项 #

• 如果需要支持无限迭代，可在队列中加入特殊终止信号（比如None），让B和C线程收到后退出循环
• 业务逻辑中若有IO操作或耗时任务，这种异步模式能大幅提升整体执行效率
• 其他编程语言（如Java、C#）可使用对应语言的并发队列（如BlockingQueue）和线程池实现相同逻辑

内容的提问来源于stack exchange，提问作者electro