5
票
承認済み
python3 multiprocessing Processでプロセスが平行で動いてくれません
質問者さんがおっしゃる通り、現在のコードでは以下の行で fl_vstack1 関数が呼び出されてしまっています。
vstack1 = mp.Process(target=stack.fl_vstack1())
この行では引数 target に stack.fl_vstack1() を代入していますが、これは関数呼び出しの構文なので関数呼び出しが起こり、その返り値が target ...
3
票
承認済み
Python3 で multiprocessing の Pool を使うと遅くなるのはなぜ?
原因
time1では、マルチプロセスにするためのオーバーヘッドが存在し、これがf(x)の計算コストに比べて大きいためと推測します。
multiprocessingの効果を確認する例
f(x)の計算に1秒掛かる場合、をtime.sleepで表現してみました。
import time
from multiprocessing import Pool
def f(x):
time....
2
票
承認済み
multiprocess python 処理がスタートしていないように見える。それはなぜでしょうか。
本家Stackoverflowにて、Spyder開発者の方がコメントしておられました。
MultiprocessingはWindowsでは動かないので以下を実行してください。
Run > Configuration per file > Execute in an external system terminal
https://stackoverflow.com/questions/...
2
票
multiprocess python 処理がスタートしていないように見える。それはなぜでしょうか。
print() が動かないのは、PicoSushi さんの回答にあるように Spyder の問題です。しかしこのコードには更に複数の問題があります。
おそらく質問者さんは2つの点について誤解なさっています。
1. global 文
1 つ目の誤解は、global 文についてです。質問文にあるような書き方をしても、グローバルスコープにある変数 n1 ~ n4 が書き換わるわけではありません。
...
2
票
承認済み
multiprocessingモジュールのterminate()による、プロセスの強制終了について
単純にtypoですね。
def whoami(name) :のprint("I'm %s, in process %s" % (name, os.getpid())に最後の)が不足しています。それを追加すれば動作します。
このくらいの小さな機能確認プログラムでは有っても無くても差は無いですが、p.terminate()の後にp.join()...
2
票
承認済み
実行スレッドによって、同じSQLite書き込み処理時間が大きく異なるのはなぜでしょうか?
メインから, データ生成スレッド(Process A を想定), データ受け取り&書き込みスレッド(M1 を想定)
2つのスレッドを呼び出して, スレッド間のデータ渡し 及び sqlite3 DBへの書き込みを行ってみました
(メイン側は, スレッドの開始, 及び終了待ち合わせ程度を行う)
データ生成スレッド(Process A 代わり) は, table_id + 10 項目 ⇨ 11 ...
1
票
承認済み
multiprocessingモジュールのJoinableQueueを使った複数のプロセスの実行について
グローバルスコープで関数呼び出しなどしている部分を、全て if __name__ == '__main__' 下に入れてください。
if __name__ == '__main__' :
dish_queue = mp.JoinableQueue()
dryer_process = mp.Process(target = dryer, args = (dish_queue,))
...
1
票
承認済み
multiprocessing.Queue と multiprocessing.manager().Queue() の問題について
ここで述べられている「共有メモリで問題が発生する」というのは、具体的にはどのような問題を意味するのでしょうか?値の順序が逆転するような問題なのか、プログラムがクラッシュするような致命的な問題なのかなどが分かりません。
プログラムクラッシュ、順序逆転などのケースも発生する可能性があります。
並行処理のプログラムの問題は、...
1
票
承認済み
PythonでGUIのボタンを押したときにmultiprocessingを動作させたい
実際には、エラーは既に別の物が発生していて、質問に書かれているのは二次的なエラーだと思われます。
実行したら先に以下のようなエラー表示が行われていました。
これの前後にkivyの動作状況ログのメッセージがあり、最後に質問に書かれたエラーメッセージが表示され、中断待ち状態になります。
Traceback (most recent call last):
File "C:\...
1
票
PythonでGUIのボタンを押したときにmultiprocessingを動作させたい
GUIから別プロセスを呼び出すことは可能なのでしょうか?
並列処理 (parallel processing: パラレルプロセッシング) を行う場合, マルチスレッド or マルチプロセス (multi-process) が選択肢としてあり,
マルチスレッドは同一プロセス空間を共有, マルチプロセスはそれぞれ別のプロセス空間で走ります
GUIライブラリー (or GUIフレームワーク)...
1
票
承認済み
Google colabを使って並列化計算の状況について
Colab にはこの回答の時点では 3 つの有料プランがあるようです
最適な Colab のプランを選択する より
Pay As You Go
Colab Pro
Colab Pro+
「Pay As You Go」についてはその下の「コンピューティング ユニットとは何ですか?」辺りを読むとよいかも
計算時間については
料金がかからないバージョンの Colab の場合、...
1
票
承認済み
Python の multiprocessing モジュールを使うと出力の順番が変わるのは何故ですか?
おそらくその書籍にも書いてあったのではないかと思いますが、multiprocessing はマルチプロセスで処理を行うためのライブラリです。複数のプロセスが同時に実行されるため、どのプロセスがより早く文字列を出力できるかは保証されていません。このため実行時の環境によってバラバラな出力順になります。今回は 1 0 2 3 という出力順でしたが、この順番は環境によって変わります。
...
1
票
subprocess.Popenのstdoutとstderrをリアルタイムに取得する
stdoutとstderrの順番が入れ替わることがある
アプリ(bash) の 入力、出力が バッファリングされている可能性があって
その バッファを アプリ側が 明示的に flush するような 起動オプションがないか調べる
https://gist.github.com/riywo/874011
bash 自体に そのようなオプションはなさそうなので、
linux ...
無効化に投票