python外部命令如何使用线程池执行命令 - 问答

在Python中，你可以使用concurrent.futures模块中的ThreadPoolExecutor类来创建一个线程池，并使用它来执行外部命令。以下是一个示例：

import subprocess
from concurrent.futures import ThreadPoolExecutor

def run_command(command):
    try:
        # 使用subprocess.run()执行命令并获取结果
        result = subprocess.run(command, stdout=subprocess.PIPE, stderr=subprocess.PIPE, text=True, check=True)
        print(f"Command executed successfully: {command}")
        print(f"Output: {result.stdout}")
    except subprocess.CalledProcessError as e:
        print(f"Error executing command: {command}")
        print(f"Error message: {e.stderr}")

# 定义要执行的外部命令列表
commands = [
    "echo 'Hello, World!'",
    "ls /",
    "pwd",
]

# 创建一个线程池
with ThreadPoolExecutor(max_workers=3) as executor:
    # 使用线程池执行命令
    executor.map(run_command, commands)

在这个示例中，我们首先导入subprocess和concurrent.futures模块。然后，我们定义了一个名为run_command的函数，该函数接受一个命令字符串作为参数，并使用subprocess.run()执行该命令。我们捕获了subprocess.CalledProcessError异常，以便在命令执行失败时处理错误。

接下来，我们定义了一个包含要执行的外部命令的列表。然后，我们创建了一个ThreadPoolExecutor实例，并使用executor.map()方法将run_command函数应用于命令列表。这将在线程池中并行执行命令。

0 赞

0 踩