multiprocessing

0熱

1答えて

パフォーマンスを向上させるために、Python（3.4.2）でマルチプロセッシングツールを使用しようとしています。私の通常のprogrammは正常に実行されていますが、大規模でネストされた辞書を処理する必要があります。私の問題を示す簡略版を添付しました。 TestProcを直接使用すると、マルチプロセッシングでは機能しません。ありがとうございました！ import multiprocessing

0熱

1答えて

LockFileExの後にファイルをコピーすることはできますか？

私はファイルをロックした後にコピーしようとしています！しかし、私はGetLastError（）= 32を取得しました。 "プロセスは別のプロセスで使用されているため、ファイルにアクセスできません。" 最初にロックされたため、ファイルを使用している同じプロセスですか？私はマルチプロセスアプリケーションで作業していて、LockFileExを使用して他のプロセスを除いて、等価ファイル情報を処理します。ま

0熱

1答えて

Pythonマルチプロセッシングを使用してWindows上で高速に実行することはできますか？

Pythonコードでマルチプロセッシングを使用する方法を理解するのは難しいです。私は今、Windows OS上でいくつかのギグと数千万のレコードであるcsvファイルを処理しており、大量の処理速度のバンプに陥り始めています。私は次のコードを持っています： import numpy as np import pandas as pd import datetime as dt df = pd.

1熱

1答えて

マルチプロセッシングマネージャとカスタムクラス

理由は分かりませんが、共有オブジェクトの共有カスタムクラスオブジェクトのメソッドに渡そうとすると、この奇妙なエラーが発生します。 Pythonのバージョン：3.6.3 コード： from multiprocessing.managers import SyncManager class MyManager(SyncManager): pass class MyClass: pass cl

0熱

1答えて

PYQT MainFrameを閉じるときにマルチプロセスを閉じるには

私はPYSide2メインフレームを持っていますが、ボタンをクリックするとプロセス名TTTを作成します。メインフレームを閉じても閉じると思います。どうすればよいですか？ class Test7(QMainWindow): def __init__(self): QMainWindow.__init__(self) self.setupUi() de

0熱

1答えて

PythonでCOMとマルチプロセッシングを同時に使用する方法はありますか？

私は2つのプロセスを作り、それらを互いに通信させようとしています。それらのうちの1つは、win32comを使用してCOMライブラリを介して値を取得し、もう1つはキューを介して最初のプロセスから値を取得し、それらを出力します。私は以下のコードは問題ありませんが、動作しません（p2プロセスは値を全く表示しません）。同じプロセス内の最初のプロセスプリントキューの値を同じプロセスで作成するだけであれば、キ

2熱

2答えて

マルチプロセッシング維持されない結果

は、私は、次のマルチプロセッシングのコードを実行しようとしました。属性finishedをrunのTrueに設定し、出力executedはrunメソッドが実行されたことを示しています。また、runの方法でself.finished=Trueの直後にprint(self.finished)という行を追加すると、出力はTrueになります。マルチ処理が終了した後にクラス属性finishedが変わるのはなぜ

2熱

1答えて

apply_async結果の順

正しく理解すると、apply_asyncはすぐにAsyncResultオブジェクトを返します。次のようにこれらのオブジェクトを収集し、すべての作業者が終了してからget（）を使用すると、その値が関数が呼び出された順序であると想定するのは安全ですか？ objRes = [None] * len(aRange) pool = Pool(processes=8) for x in aRange:

0熱

2答えて

python kafkaコンシューマを使ったマルチプロセッシング

私は1つのトピック（demo-topic）と1つのパーティションを持つpythonでアプリケーションを作ろうとしています。このトピックでは、メッセージはランダムにプッシュされます私はこのメッセージを使用してバックグラウンド計算に時間がかかります（消費者1）（デモグループ）が1人あります。アマゾンでこのアプリケーションを使用すると、新しく作成されたマシンが同じグループ（デモグループ）の別のコン

1熱

1答えて

Pythonのマルチスレッド/ロギングモジュールに関する問題

私は、子プロセスごとにログを作成するプログラムを同時に実行しています。最初に私のセットアップとそれから直面している問題について説明します。ここに私の主なモジュールは以下のとおりです。 mp_handler.py： import logging import multiprocessing as mp def mp_handler(target, args_list): # con