問題タブ [pathos]

ftpからファイルを順番にダウンロードしようとすると、完全に機能します

しかし、同じことを並行してやろうとすると、

または、次の2行のコメントを解除しようとすると

私はこのエラーを受け取ります:フロートが必要です。しかし、スタックトレースがないので、デバッグできます

私の完全なコードは次のとおりです。

私はPythonの経験があまりないので、私のコードをチェックしていただければ幸いです. この場合、マルチプロセッシングを実装する最良の方法は何ですか?

OSX でウェブカメラを読み込んでいますが、これは次の単純なスクリプトで正常に動作します。

私は今、ビデオを別のプロセスで読みたいと思っています。スクリプトははるかに長く、Linux の別のプロセスでビデオを正しく読み込んでいます。

.read()これは Linux では問題なく動作しますが、OSX では、作成されたcv2.VideoCapture(device)オブジェクト ( var に格納されている)に対して実行できないように見えるため、問題が発生していますself._cap。

いくつかの検索の後、私はこの SO answerを見つけました。これは、おそらくいくつかの非常に有用な改善があると思われる pythons multiprocessing の代替であるBilliardを使用することを提案しています。したがって、ファイルの先頭で、以前のマルチプロセッシング インポートの後にインポートを追加しただけです (効果的にオーバーライドしますmultiprocessing.Process)。

video_process変数のインスタンス化の直前に、次のように使用forking_enableします。

したがって、このバージョン（ここでは Pastebin）でファイルを再度実行すると、次のエラーが発生します。

pickle.PicklingError: ピクルできません:メインの.stream_functionとして見つかりません

そのエラーを検索すると、答えの長いリストを含む SO の質問にたどり着きました。そのうちの 1 つは、これを解決するためにdill シリアライゼーション ライブラリを使用することを提案しました。ただし、その lib はPathos マルチプロセッシング フォークで使用する必要があります。だから私は単純にマルチプロセッシングのインポート行を

に

しかし、Array、 、ValueおよびはパッケージProcessに存在しないようです。pathos.multiprocessing

そして、この時点から、私は完全に迷っています。私はほとんど十分な知識を持っていないものを探しています。また、どの方向に検索またはデバッグする必要があるかさえわかりません。

では、私よりも明るい魂が、別のプロセスでビデオをキャプチャするのを手伝ってくれるでしょうか? すべてのヒントは大歓迎です！

sympy.lambdify からラム化された関数で pool.map を使用しようとすると、dill からエラーがスローされます。

dill.dump でオブジェクトをダンプしようとしたときにもこのエラーが発生しましたが、dill.settings['recurse'] = True. ただし、dillフラグをインポートして設定しても、pool.map() には影響がないようです。

さらに、関数の実際の sy.lambdify 作成を並列化できるようにしたいと考えています。

これも同様のエラーで失敗します。

最初のケースの回避策を見つけました: 関数呼び出しを非 sympy にラップするだけです:

しかし、これは 2 番目のケース (lambdify の並列化) では役に立ちません。pathos名誉を強制する方法はありdill.settingsますか？