python-multiprocessing

    1

    1答えて

    私はPython Multiprocessing.poolについて簡単に質問しています。ここに私のコードです: import multiprocessing as mp info =999 def func(x): global info print info return x**3 pool = mp.Pool() for i in range(2):

    1

    2答えて

    私はマルチプロセッシングが私にとって新しいものだと言います。私はそれについていくつか読んだが、それは私をもっと混乱させる。私は簡単な例でそれを理解したい。最初の関数に2つの関数があると仮定しましょう。変数 'a'をインクリメントして 'number'変数に代入します。次に、最初に関数を開始し、1秒ごとに 'number'変数を出力します。次のようになります。 global number def

    1

    1答えて

    497パンダのデータフレームが.parquetファイルとして格納されたフォルダがあります。フォルダの合計サイズは7.6GBです。 私は単純な取引システムを開発しようとしています。したがって、私は2つの異なるクラスを作成します。主なものはPortfolioクラスです。このクラスは、データフォルダ内のすべての単一データフレームに対してAssetオブジェクトを作成します。 import os impo

    -1

    1答えて

    私はPythonでThreadと連携するコードを持っていますが、私はスピードアップをうまく理解しているかのようにProcessに切り替える必要があります。 はここスレッドでコードがあります: threads.append(Thread(target=getId, args=(my_queue, read))) threads.append(Thread(target=getLatitude, a

    0

    1答えて

    多くの文字列正規表現を1つの長い文字列にマッチさせ、すべてのマッチでデリミタを数えようとしています。同時に、一度に多くの正規表現を検索するmultiprocessingを使用して: with open('many_regex', 'r') as f: sch = f.readlines() with open('big_string', 'r') as f: text =

    1

    1答えて

    Pythonのマルチプロセッシングモジュールを使用して、別のオブジェクトを作成し、そのオブジェクトをloops_foreverメソッドとして呼び出す新しいプロセスを開始します。私は私のメインクラスで : import OtherService from multiprocessing import Process my_other_service = OtherService(address=

    1

    1答えて

    Multiprocessingでしばらくの間苦労しています。Pythonです。 2つの独立した関数を同時に実行し、両方の計算が終了するまで待ってから、両方の関数の出力を続けます。 マルチプロセッシングの他の例が見つかりましたが、1つの関数しか使用しなかったか、出力を返しませんでした。誰でもこれを行う方法を知っていますか?どうもありがとう!

    1

    1答えて

    プールを使用して16のプロセッサ間ですべてのジョブを均等に分散しようとしています。私が気づいたのは、当初は16プロセスが生成されたということです。数秒後に2つのプロセスだけが少数のジョブに対して残りのすべてのジョブを実行します。どんなに負荷を増やしても、それに取り組んでいるプロセスはまったく減少していないようです。最終的には、1つまたは2つのプロセスだけが残りのジョブを通過します。 ここに私のコー