使用 Python 启动并行任务
如果一个 Python 程序可以被分解成子程序,并且子程序的处理过程互相独立,则每个子程序都可以在总体程序运行的时候并行运行。这个概念是 Python 中的并行处理。
使用多处理
此模块可用于创建主进程的许多子进程,这些子进程可以并行运行。在下面的程序中,我们初始化一个进程,然后使用 run 方法来运行多个子进程。通过使用进程 ID,可以在 print 语句中看到不同的子进程。我们还使用 sleep 方法来看到文本语句以很小的延迟依次打印出来。
示例
import multiprocessing import time class Process(multiprocessing.Process): def __init__(self, id): super(Process, self).__init__() self.id = id def run(self): time.sleep(1) print("Running process id: {}".format(self.id)) if __name__ == '__main__': p = Process("a") p.start() p.join() p = Process("b") p.start() p.join() p = Process("c") p.start() p.join()
输出
运行上面代码会得到以下结果 −
Running process id: a Running process id: b Running process id: c
广告