問題タブ [concurrent.futures]

futures バックポート パッケージを使用して、Python で ThreadPoolExecutor を使用しようとしています。ただし、問題は、すべてのスレッドが同時に実行されるため、実際のプーリングが行われないことです。より具体的には、5 つではなく、その関数の 10 スレッドを取得し、次に他のスレッドを取得します。私は次のコードを使用していますが、何か間違っていると思いますか、それとも単にバックポートされた実装ですか? ありがとうございました！

重い CPU バウンドの計算を実行するlong_task関数があり、新しい asyncio フレームワークを使用して非同期にしたいと考えています。結果のlong_task_async関数はProcessPoolExecutor、GIL によって制約されないように作業を別のプロセスにオフロードするために a を使用します。

問題は、何らかの理由でconcurrent.futures.Futurefrom から返されたときに返されたインスタンスProcessPoolExecutor.submitが をスローすることTypeErrorです。これは設計によるものですか？asyncio.Futureそれらの先物はクラスと互換性がありませんか? 回避策は何ですか？

また、ジェネレーターはピクル化できないため、クルーチンを に送信するProcessPoolExecutorと失敗することにも気付きました。これにもきれいな解決策はありますか？

私の理解では、concurrent.futures はピクル引数に依存して、それらを異なるプロセス (またはスレッド) で実行していました。ピクルス化は引数のコピーを作成するべきではありませんか? Linux ではそうしていないようです。つまり、明示的にコピーを渡す必要があります。

次の結果を理解しようとしています。

コードは次のとおりです。

いったいどこ[97, 32, 17, 15, 57, 97, 63, 72, 60, 8]から来ているのでしょうか？それは に渡されたシーケンスの 1 つでもありませんsubmit。

結果は、Python 2 ではわずかに異なります。

Scala-IDE 3.0.3 (Scala 2.10.4 ベース) を使用すると、次のコードはList、future から計算された の最初の 10 個の値とFuture completedメッセージを表示することで正しく完了します。

ただし、範囲List.range(1, 50)をに変更しList.range(1, 5000)ても、何も表示されません (Failureトリガーされません)。論理的には、メモリの問題に関連しているようですが、そこで何が起こっているのかわかりません。

さらに奇妙なことに、このコードを REPL で実行しても問題は発生しません。私はそこに何が欠けていますか？

Michael Genesereth のGeneral Game Playing (GGP) Coursera コースを受講しています。GGP では、プレイヤーは移動するために一定の時間が与えられます。私はScalaでプレーヤーを書いています。(基礎となる GGP コードベースは Java です。) Scala は、計算が所定の時間内に応答することを保証するために使用できるサポートを提供しますか (または Scala ライブラリはありますか)。

1 つのプロセス (プロセス 'A') がリクエストを受け取り、それを (concurrent.futures から) ProcessPool に入れる Python アプリケーションを作成しようとしています。この要求を処理する際に、メッセージを 2 番目のプロセス (プロセス 'B') に渡す必要がある場合があります。トルネードの iostream モジュールを使用して、接続をラップして応答を取得しています。

プロセス A は、ProcessPool 実行内からプロセス B に正常に接続できません。どこが間違っていますか？

プロセス A に最初の要求を行うクライアント:

最初のリクエストを受け取ったプロセス A:

プロセス A から中継されたリクエストを受信するプロセス B:

最後に、「read_until」メソッドで発生したプロセス A から返されたエラー: