os.system() 即使在互斥锁下也会导致 print() python 函数的控制台输出无效

Question

我制作了一个脚本，它通过 ThreadPool 中的os.system() 调用一些程序并将工作结果打印到控制台。简化后的代码是这样的：

import os
from concurrent.futures import ThreadPoolExecutor, as_completed
import multiprocessing
from threading import Lock

print_mutex = Lock()
def print_safe(text):
    with print_mutex:
        print(text, flush=True)

def print_smth():
    res = os.system("")
    print_safe("1")

with ThreadPoolExecutor(max_workers = multiprocessing.cpu_count()) as thread_pool:
    future_results = [thread_pool.submit(print_smth) for i in range(40)]

    for future in future_results:
        future.result()

但是在控制台输出中我收到了这样的意外结果：

如果我评论res = os.system("") call，则输出有效。

为什么 os.system() 会以这种方式影响打印功能？

实施流程调用以避免此类问题的正确方法是什么？

Answer 1

发生了什么：

Threadpool 创建一个并行工作的线程池。但是，您的主线程仍然是单线程。如果您的作业不需要时间（小于循环调用函数本身的周期），它将在调用下一个函数所需的时间内完成，它将显示为同步的。

os.system 在你的电脑上花费了一些时间（这可能会根据速度、操作系统和 CPU 数量而变化），因此线程同时结束，并且由于调用 os.system 的工作延迟，它们正在彼此相邻打印，因为它们在主应用程序的同一个单线程循环中打印（打印到控制台的那个）。

如果您的函数确实有效，您会看到预期的结果。