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