Python多进程能否实现单进程一行输出？无额外依赖方案咨询

方案1：合并单次输出 #

直接将任务的前后输出合并为一次打印操作，确保每个进程仅输出完整的一行内容，从根源避免拆分输出导致的交错问题：

from multiprocessing import Pool
import time

def do_work() -> None:
    # 模拟耗时操作
    time.sleep(0.1)
    
    # 合并输出为单次打印，保证整行内容一次性输出
    print("Start work...done")

def main():
    workers = 4
    with Pool(workers) as p:
        for i in range(100):
            p.apply_async(func=do_work)
    
        p.close()
        p.join()

if __name__ == "__main__":
    main()

方案2：使用进程锁同步输出 #

如果必须保留"先打印开头、执行耗时操作、再打印结尾"的分步逻辑，可以通过multiprocessing.Lock实现输出同步，确保同一任务的两次打印不会被其他进程打断：

from multiprocessing import Pool, Lock
import time

# 初始化进程锁，用于同步输出操作
lock = Lock()

def do_work(lock) -> None:
    # 加锁后打印开头，避免其他进程插入输出
    with lock:
        print("Start work", end="")
    
    # 模拟耗时操作
    time.sleep(0.1)
    
    # 加锁后打印结尾，保证当前任务的输出连贯
    with lock:
        print("...done")

def main():
    workers = 4
    with Pool(workers, initargs=(lock,)) as p:
        for i in range(100):
            p.apply_async(func=do_work, args=(lock,))
    
        p.close()
        p.join()

if __name__ == "__main__":
    main()

补充说明 #

• 方案1实现简单，依赖Python的行缓冲特性，整行打印几乎不会出现输出交错，适合无需分步打印的场景。
• 方案2适用于必须保留分步输出逻辑的场景，通过锁机制强制保证同一任务的输出连续性，完全符合需求格式。

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