質問をすることでしか得られない、回答やアドバイスがある。

15分調べてもわからないことは、質問しよう!

新規登録して質問してみよう
ただいま回答率
85.50%
Python 3.x

Python 3はPythonプログラミング言語の最新バージョンであり、2008年12月3日にリリースされました。

Python

Pythonは、コードの読みやすさが特徴的なプログラミング言語の1つです。 強い型付け、動的型付けに対応しており、後方互換性がないバージョン2系とバージョン3系が使用されています。 商用製品の開発にも無料で使用でき、OSだけでなく仮想環境にも対応。Unicodeによる文字列操作をサポートしているため、日本語処理も標準で可能です。

Q&A

解決済

1回答

1196閲覧

別のモジュールにmultiprocessingを用いて実装したマルチプロセスが実行に失敗し、無限ループに入る

hokaria

総合スコア1

Python 3.x

Python 3はPythonプログラミング言語の最新バージョンであり、2008年12月3日にリリースされました。

Python

Pythonは、コードの読みやすさが特徴的なプログラミング言語の1つです。 強い型付け、動的型付けに対応しており、後方互換性がないバージョン2系とバージョン3系が使用されています。 商用製品の開発にも無料で使用でき、OSだけでなく仮想環境にも対応。Unicodeによる文字列操作をサポートしているため、日本語処理も標準で可能です。

1グッド

0クリップ

投稿2023/01/22 21:04

編集2023/01/23 16:08

前提

Anacondaにてconda仮想環境を構築したうえで、Anaconda Prompt から実行しています。
Pythonのバージョンは3.9.15です。
(追記:OSは Windows 10 で、Anacondaのバージョンは22.11.1です。
Anaconda Prompt で $ activate env1 してconda環境に移ったうえで実行しています)

CPUバウンドなタスクを速く処理すべく、multiprocessingモジュールのPoolクラスを用いて、実行ファイルとは別のモジュールの関数内でマルチプロセスを実装しています。
ただ、その別モジュールを import して関数を実行すると、無数のエラーが間断なく発生し続けてしまいます。
また、実行ファイルじたいのプロセスを繰り返してしまいます。

実現したいこと

実現したいことは、次のとおりです。

  • エラーが発生しない
  • 実行ファイル( sample.py )のプロセスを繰り返さない(重要)

非常に困っております。どうかよろしくお願いいたします。

実行コマンドとエラーメッセージ

bash

1$ python sample.py 2hello 3hello 4hello 5hello 6hello 7hello 8# 無数のエラーメッセージ 9hello 10hello 11# 無数のエラーメッセージ 12hello 13# 無数のエラーメッセージ 14hello 15# 無数のエラーメッセージ 16hello 17hello 18# 無数のエラーメッセージ 19hello 20# 無数のエラーメッセージ 21# こんなのがずっと続きます

該当のソースコード

Python:sample.py

1import mymodule 2 3print('hello') 4mymodule.main()

Python:mymodule.py

1from multiprocessing import Pool 2import time 3import random 4 5def slow_task(n: int): 6 """2~3秒かかる遅い処理""" 7 seconds = random.uniform(2, 3) 8 time.sleep(seconds) 9 print(f'slow task {n}') 10 11def main(): 12 with Pool(5) as pool: 13 results = pool.map(slow_task, list(range(10))) 14 15if __name__ == '__main__': 16 main()

補足情報

なお、$ python mymodule.py というようにモジュールをそのまま実行すれば正常にマルチプロセスがなされます。

bash

1$ python mymodule.py 2slow task 0 3slow task 4 4slow task 2 5slow task 3 6slow task 1 7slow task 5 8slow task 7 9slow task 8 10slow task 6 11slow task 9
hokaria👍を押しています

気になる質問をクリップする

クリップした質問は、後からいつでもMYページで確認できます。

またクリップした質問に回答があった際、通知やメールを受け取ることができます。

バッドをするには、ログインかつ

こちらの条件を満たす必要があります。

y_waiwai

2023/01/22 23:31

エラーが出たなら、エラーメッセージを提示しましょう エラーメッセージは、よけいな省略翻訳しないで出たそのママをコピペで提示してください
退会済みユーザー

退会済みユーザー

2023/01/23 04:14

エラーメッセージが気になって手元で走らせましたが、 - try exceptでトラップした上でsys.exit()が効かない - exitできないうえに、猛烈な勢いでなぜかループに入る - 結果コピペできず、終わらせるには強制終了しかない という感じでした。 表示された文字列からググった感じだと、全文は以下のURLにあるエラーっぽかったです。 https://superfastpython.com/multiprocessing-pool-python/
hokaria

2023/01/23 07:08 編集

>dameoさん OSと実行環境を追記いたしました。たしかに、プロセス起動はos.fork()しかりOSに依存しそうな問題で、横着せず書いておくべきでした。 また、if __name__ == '__main__': をすっかり忘れていました。が、モジュールでない限りこれを設ける場合と設けない場合でそれほど差はないだろうとこれまで思っていたものを、今回はもろに影響を受けました。示唆していただきありがとうございます。 >y_waiwaiさん エラーメッセージがとにかく多く、しかも複数のエラーメッセージが同時に吐かれ、たがいのメッセージが割り込みあっていて混沌としているので、記しませんでした。申し訳ありません。 >fourteenlengthさん わざわざ実行していただいてありがとうございます。 そして、エラーメッセージなどの状況を詳しく説明いただきありがとうございます。まさにそのような状況で間違いありませんでした。
guest

回答1

0

ベストアンサー

Windowsでしか起きない現象だそうで、私も勉強になりました。
また、細かい説明は日本語のリファレンスに見つかりましたので、ここには書きません。

動くコードは以下を参照ください。

Python3

1from multiprocessing import freeze_support # <--エラーメッセージを元に追加 2import mymodule 3 4if __name__ == "__main__": # <-- お行儀良く変更 5 freeze_support() # <--エラーメッセージを元に追加 6 print('hello') 7 mymodule.main()

投稿2023/01/23 04:25

退会済みユーザー

退会済みユーザー

総合スコア0

バッドをするには、ログインかつ

こちらの条件を満たす必要があります。

hokaria

2023/01/23 06:19

fourteenlengthさん、手を尽くしていただき本当にありがとうございました。 自分の環境では一応、freeze_support()なしで if __name__ == '__main__': を設けるだけで目的は達成されましたが、コメントのほうでいただいたリンクのページを読むとfreeze_support()はあったほうがいいかもしれませんね。 即回答いただき解決もできました。本当にありがとうございました。
guest

あなたの回答

tips

太字

斜体

打ち消し線

見出し

引用テキストの挿入

コードの挿入

リンクの挿入

リストの挿入

番号リストの挿入

表の挿入

水平線の挿入

プレビュー

15分調べてもわからないことは
teratailで質問しよう!

ただいまの回答率
85.50%

質問をまとめることで
思考を整理して素早く解決

テンプレート機能で
簡単に質問をまとめる

質問する

関連した質問