欢迎访问宙启技术站
智能推送

使用Python中的run()函数实现并行运行多个进程

发布时间:2024-01-18 18:25:13

在Python中,可以使用run()函数来实现并行运行多个进程。run()函数是subprocess模块中的一个函数,它用于创建新的进程并执行指定的命令。下面是一个使用run()函数实现并行运行多个进程的示例:

import subprocess

def run_process(cmd):
    subprocess.run(cmd, shell=True)

if __name__ == '__main__':
    # 定义要执行的命令列表
    commands = [
        'echo Hello',
        'echo World',
        'ping -c 4 google.com',
    ]

    # 创建进程列表
    processes = []

    # 启动并行进程
    for cmd in commands:
        p = subprocess.Popen(cmd, shell=True)
        processes.append(p)

    # 等待所有进程完成
    for p in processes:
        p.wait()

在上面的例子中,我们定义了一个run_process()函数,用于调用run()函数并执行指定的命令。在if __name__ == '__main__':语句块中,我们定义了要执行的命令列表commands,其中包括了三个命令。

然后,我们创建了一个进程列表processes,用于存储所有创建的进程对象。接着,我们使用subprocess.Popen()函数创建并启动了多个并行的进程,并将它们添加到进程列表中。

最后,我们使用wait()方法等待所有进程完成。wait()方法会阻塞当前进程,直到调用该方法的进程结束。

通过以上代码,我们将能够在Python中实现并行运行多个进程。这将提高程序的效率,特别是在需要同时执行多个任务的情况下。