Pythonマルチプロセス環境におけるデータ共有のメカニズムと実装
Pythonのmultiprocessingモジュールを用いて並列処理を構築する際、親プロセスと子プロセス間で状態を共有しようとすると、意図しない動作に直面することがあります。以下のスクリプトは、セマフォを用いて同時実行数を制御しつつ、複数のタスク結果を辞書へ集約する実装例です。
import time
from multiprocessing import Process, Semaphore
def execute_task(semaphore ...
6月4日 22:34 投稿