使用 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

更新于:2020 年 7 月 10 日

315 人查看

启动您的职业

完成课程获得认证

入门
广告