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

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

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

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

Q&A

解決済

1回答

1403閲覧

pythonで並列処理

NoPython_Nolife

総合スコア49

Python 3.x

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

0グッド

0クリップ

投稿2017/11/01 08:28

編集2017/11/02 07:24

pythonで下記パッケージをインストールして、

from multiprocessing import Process

下記コードで並列処理を実行させました。

python

1def df(s): 2 return s 3 4if __name__ == '__main__': 5 wk = 3 6 processes = [] 7 for pn in range(wk): 8 p = Process(target = df, args = (sm[pn],)) 9 p.start() 10 processes.append(p) 11 12 for p in processes: 13 p.join()

自作関数dfをwkで指定した並列数で並列処理を実行させた場合、
df関数内で構築したデータフレームなどのデータの取り出し方がわかりません。

ご教授いただけると助かります。
よろしくお願い致します。

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

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

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

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

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

guest

回答1

0

ベストアンサー

Processを使い値を受け取る方法はいくつかあります。例えばQueueです。
大まかな流れは、putした後にgetで取り出します。

python

1from multiprocessing import Queue, Process 2 3 4def df(s, queue): 5 queue.put(s) 6 7 8if __name__ == '__main__': 9 sm = [1, 2, 3] 10 queue = Queue() 11 processes = [] 12 13 for s in sm: 14 p = Process(target=df, args=(s, queue)) 15 p.start() 16 processes.append(p) 17 18 for p in processes: 19 p.join() 20 result = queue.get() 21 print(result) 22 23

今回の例ですと、ProcessPoolExecutorを使うほうが楽に書けます。

python

1from concurrent.futures import ProcessPoolExecutor 2 3 4def df(s): 5 return s 6 7 8if __name__ == '__main__': 9 sm = [1, 2, 3, 4, 5] 10 with ProcessPoolExecutor(max_workers=3) as executor: 11 for result in executor.map(df, sm): 12 print(result) 13

投稿2017/11/01 09:16

編集2017/11/01 21:49
toritoritorina

総合スコア972

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

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

NoPython_Nolife

2017/11/02 07:20

ほんとに助かりました!ありがとうございます!
guest

あなたの回答

tips

太字

斜体

打ち消し線

見出し

引用テキストの挿入

コードの挿入

リンクの挿入

リストの挿入

番号リストの挿入

表の挿入

水平線の挿入

プレビュー

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

ただいまの回答率
85.50%

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

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

質問する

関連した質問