信号量实现顺序输出时仅能单线程运行，如何兼顾3线程并发与顺序打印效果

现有实现的核心问题 #

• 当前基于值为1的信号量的实现，把业务执行逻辑和打印输出逻辑一起包裹在互斥临界区里
• 互斥机制要求线程必须从acquire()开始，到release()结束全程独占资源，导致线程的业务操作完全串行，失去多线程并发的价值
• 目前的输出顺序虽然符合预期，但三个线程没有任何并行执行的空间

核心实现思路 #

核心是缩小锁的保护范围，完全解耦业务执行和打印调度：

• 所有线程启动后，完全无锁、并行执行各自的业务逻辑（比如设备连接、状态检测这类耗时操作）
• 每个线程完成自身业务逻辑后，将需要打印的内容暂存到独立的内存缓冲区，不直接调用打印接口
• 按预设的输出顺序，依次等待对应线程的业务执行完成，再由独立的调度流程统一读取缓冲区内容，在打印锁的保护下按固定顺序输出

可运行参考代码 #

import threading
import time
from random import random

# 全局存储每个线程的输出内容、执行完成标志
output_buffer = {}
thread_ready_event = {
    'a': threading.Event(),
    'b': threading.Event(),
    'c': threading.Event()
}
# 打印专用互斥锁，仅保护打印操作，不约束业务逻辑执行
print_lock = threading.Lock()

def config_worker(port, router_id):
    # --------------------------
    # 以下为完全并发的业务逻辑，无任何锁约束，所有线程可同时运行
    # 模拟路由器连接、隧道状态检测的耗时操作
    time.sleep(random() * 2)
    # --------------------------
    # 业务逻辑完成后，将输出内容存入缓冲区
    output_lines = [
        f'PASS : Tunnel1 is UP from  router {router_id}',
        f'PASS : Tunnel2 is UP from  router {router_id}',
        f'PASS : Tunnel3 is UP from  router {router_id}'
    ]
    output_buffer[port] = output_lines
    # 标记当前线程业务执行完成，可被调度输出
    thread_ready_event[port].set()

def connect():
    config_threads_list = []
    devices = [('a', 1), ('b', 2), ('c', 3)] # 绑定端口与对应路由器ID
    for port, router_id in devices:
        print ('Creating thread for: ', port)
        config_threads_list.append(threading.Thread(target=config_worker, args=(port, router_id)))

    print ('\n---- Begin get config threading ----\n')
    # 启动所有线程，此时所有线程会并行执行业务逻辑
    for config_thread in config_threads_list:
        config_thread.start()

    # 按预设的a→b→c顺序完成打印调度，保证输出顺序固定
    for expected_port, _ in devices:
        # 等待对应端口的线程业务逻辑执行完成
        thread_ready_event[expected_port].wait()
        # 在打印锁保护下输出对应线程的缓存内容
        with print_lock:
            for line in output_buffer[expected_port]:
                print(line)

    # 等待所有线程执行退出
    for config_thread in config_threads_list:
        config_thread.join()

if __name__ == "__main__":
    connect()

方案实际效果 #

• 真并发：所有线程的业务操作并行运行，整体执行耗时约等于单个线程的最长业务耗时，远快于串行执行的总时长
• 顺序稳定：无论哪个线程先完成业务执行，最终的打印输出都会严格保持router1→router2→router3的固定顺序，与预期输出格式完全匹配
• 低竞争：互斥锁仅覆盖打印输出的极短临界区，锁等待的时间成本几乎可以忽略，不会成为并发执行的瓶颈

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