pathos

0熱

1答えて

私は from pathos.multiprocessing import ProcessingPool pool = ProcessingPool(4) pool.map(...) を実行していると、実行時に印刷されます以下： not in depth 2 not in depth 3 not in depth 1 not in depth 2 not in depth 3 n

0熱

1答えて

マルチプロセッシングと同等の機能です.Poolのパススルーでの結合

私はmultiprocessing.Processを使用して、機能が長時間実行されないようにしています。 pythonのmultiprocessingの代わりにpathosを使用したいのですが（標準のマルチプロセッシングパッケージでは処理できないため）、いくつかの機能が不足しているようです：pathosに何も見つかりませんタイムアウト引数を持つjoinが可能です。私はある時間が過ぎてからプロセス

1熱

1答えて

完了時にPython ThreadPoolを使用してリソースをシャットダウンする

私はPathos ProcessPoolを使用して、多くのデータポイントで並列に機能data()を実行するスクリプトを使用しています。機能がdata()計算と呼ばれ、Databaseと呼ばれる単一のオブジェクトに結果を送信すると、プッシュの多くは、DBに送信されているので、私はシンプルなキューを追加したキューサイズが500より大きい場合、それはにプッシュされますデータベース。問題は、すべてのデ

0熱

1答えて

Pythonで複数のスレッドで2つの関数呼び出しが常に連続して行われるようにするにはどうすればよいですか？

私はこのようなパトスを使用しています： from pathos.multiprocessing import ProcessingPool as Pool def foo(bar): fn1(bar) fn2(bar) Pool().map(foo, data) 私はfn1とfn2は何のスレッドがfn1, fn1, fn2, fn2のような順序で関数呼び出しを生成しな

0熱

1答えて

Pathosマルチプロセッシング酸洗いの問題

私はチームで行っているいくつかのテストのための自動化フレームワークを開発しています。我々は、この酸洗エラーに遭遇しており、いくつかの研究を行った後、私は解決策の数に出くわしたとそれに付随するgithubのページをレビュー： Python multiprocessing pickling error Multiprocessing: How to use Pool.map on a function

-1熱

1答えて

Python pathosプロセスプール非デーモンですか？

マルチプロセッシングモジュールではなく、python3でパススルーで非デーモンプロセスを実装するにはどうしたらいいですか？具体的には、私はを参照しています：この投稿への答えはマルチプロセッシングモジュールを介して非鬼神のプロセスを実装し Python Process Pool non-daemonic? 。残念ながら、このモジュールは、他のオブジェクト間ラムダ機能を酸洗いすることはできませんが、

0熱

1答えて

pathos ImportError：__import__が見つかりません

私は以下のコードをLinux上で実行しています - UbuntuでPython 3.5を仮想環境で使用し、以下のエラーを取得しています。スレッディングやリストの理解のためにはうまく動作しますが、マルチプロセッシングの動作に問題があります。ここで multiprocess.pool.RemoteTraceback: """ Traceback (most recent call last

0熱

2答えて

ハンドオーバの仕方* pathosのamapへのargs

私は以下の問題があります：pathos.multiprocessingからのamapを使用したいと思います。 import pathos as pt class Foo: def __init__(self): pass def f(self, a, b, c): return a + b + c def g(self):

1熱

1答えて

Manger.Namespace（）内のマルチプロセッシングのキュー

私は現在、multiprocessingモジュールを使用して、マルチスレッドの方法でいくつかのメソッドを実行するはずのクラスを作成しています。 nの労働者のPoolを使用して実際の計算を実行します。現在、nのアクティブワーカーのそれぞれに、0とnの間のインデックスを他の計算に割り当てるようにしました。これを行うために、共有されたQueueを使用してインデックスを割り当てたいと思っていました。たびた

-1熱

1答えて

私がパススルーを使用するときにimporterror

マルチプロセッシングにパススルーを使用しようとしましたが、プロセスを開始すると、ImportError:no module named ppが得られます。 githubからパスロをダウンロードし、python setup.pyでインストールします。python version 2.7.8、