### 实现 Python 中非阻塞执行命令并实时获取输出 为了实现这一目标，`subprocess.Popen` 是一种常用方法。通过设置 `stdout=subprocess.PIPE` 和 `stderr=subprocess.PIPE` 参数来捕获标准输出和错误流，并利用多线程或者异步 I/O 来防止程序被子进程的标准输出所阻塞。 下面是一个基于 `threading.Thread` 的例子： ```python import subprocess import threading def read_output(pipe, func): try: for line in iter(pipe.readline, b''): func(line.decode('gbk').strip()) finally: pipe.close() cmd = ['ping', 'www.example.com'] # Replace with your command here. p = subprocess.Popen(cmd, stdout=subprocess.PIPE, stderr=subprocess.PIPE, bufsize=1, universal_newlines=True) output_thread = threading.Thread(target=read_output, args=(p.stdout, print)) error_thread = threading.Thread(target=read_output, args=(p.stderr, print)) output_thread.daemon = True error_thread.daemon = True output_thread.start() error_thread.start() p.wait() ``` 上述代码创建了一个新的线程用于读取来自外部命令的标准输出和标准错误管道的内容[^1]。每当有新数据可用时就会调用指定函数（在这个案例中是内置的 `print()` 函数），从而实现了即时打印的效果。 对于更现代的方式，在 Python 3.5 及以上版本推荐使用 `asyncio` 库配合协程来进行非阻塞操作: ```python import asyncio async def run_command(*args): process = await asyncio.create_subprocess_exec( *args, stdout=asyncio.subprocess.PIPE, stderr=asyncio.subprocess.STDOUT ) while True: line = await process.stdout.readline() if not line: break message = line.decode().rstrip() print(message) return await process.wait() loop = asyncio.get_event_loop() try: loop.run_until_complete(run_command('ping', '-c', '4', 'example.org')) finally: loop.close() ``` 这段代码展示了如何使用 `asyncio.create_subprocess_exec` 创建一个新的子进程对象，并通过循环不断读取其产生的每一行输出直到结束。这种方式更加高效且易于管理资源释放等问题[^2]。