future

5熱

1答えて

asyncを使用して生成されたいくつかのスレッドの先をリストに保存して、後でその結果を取得したいと考えています。 future<int> f = async(doLater, parameter); list<future<int>> l; l.push_back(f); しかし、コンパイラのプリント /usr/include/c++/4.7/bits/stl_list.h:115:71:

28熱

2答えて

失敗した未来の例外のマップ

mapExceptionがスカラーで失敗したFutureの最もクリーンな方法は何ですか？は、私が持っていると言う： import scala.concurrent._ import scala.concurrent.ExecutionContext.Implicits.global val f = Future { if(math.random < 0.5) 1 else thr

6熱

1答えて

グローバルExecutionContextが将来のブロックでデフォルトパラメータでないのはなぜですか？

FuturesまたはActorsレスポンスで並行コードを書くときには、実際にはExecutionContext.Implicits.globalを手作業でインポートすると、本当に面倒です。デフォルトパラメータとして作られていない理由を説明しようとしました。doneとStrategyがScalaz Concurrentであるようです。これは、コード内のすべてのインポートを挿入/削除するのではなく、非

10熱

2答えて

ブロッキングが発生する場所を管理しながら、代わりに将来{...}

This answerの新しいスレッドは、scala.concurrent.Futureにjava.util.concurrent.Futureを変換する方法を指示する理由： import java.util.concurrent.{Future => JFuture} import scala.concurrent.{Future => SFuture} val jfuture: JFut

7熱

1答えて

なぜJava 8 CompletableFuture thenComposeは完了の順序によって異なる例外を生成するのですか？

私はJava 8 CompletableFuture thenComposeメソッドの奇妙な動作に遭遇しました。私は実行の順番だけが異なる2つのテストを持っています。どちらのテストも、thenComposeで生成されたCompletableFutureの失敗をシミュレートします。 @Test public void completedAfter() { CompletableFutur

12熱

1答えて

ダーツ、どのようにあなた自身の関数で返す未来を作成するには？

あなたのメソッドから返すようにDartで独自の未来を作成することは可能ですか？または、ダーツの非同期ライブラリメソッドから将来組み込みの戻り値を返す必要がありますか？ List<Base> aListOfItems = ...; Future<List<Base>> GetItemList(){ return new Future(aListOfItems); }

8熱

1答えて

複数の先物のコールバックを待っています

最近、私はAPIを使用して少し仕事を掘り下げました。 APIは、Unirest httpライブラリを使用してWebからの受信作業を簡素化します。もちろん、APIサーバーからデータが呼び出されるため、APIへの非同期呼び出しを使用して効率的に処理しようとしました。次のように私の考えは、構造化されています。したがって、私はすべてのデータを持っている必要があり、データから集め先物表示データ+付加的

5熱

2答えて

Future.onComplete：メソッドのシグネチャに

/** When this future is completed, either through an exception, or a value, * apply the provided function. * * If the future has already been completed, * this will either be appli

20熱

1答えて

ProcessPoolExecutorはconcurrent.futuresからマルチプロセスより遅いです。プール

私は新しい光沢のあるconcurrent.futuresモジュールをPython 3.2で導入して実験していましたが、ほぼ同じコードで、concurrent.futuresのプールを使用していることがわかりましたwayは、multiprocessing.Poolを使用するよりも遅いです。これはマルチプロセッシングを使用したバージョンです： def hard_work(n): # Rea

5熱

2答えて

Scala未来のエラーをキャッチ

Scalaの未来が失敗し、その失敗を "観測"する継続がない場合（または唯一の継続はmap/flatMapを使用し、失敗の場合は実行しない）、エラーは検出されません。私はそのようなエラーが少なくとも記録されるようにしたいので、私はバグを見つけることができます。 Net Tasksでは、GCによってTaskオブジェクトが収集されたときに「監視されないタスクの例外」を検出する可能性があるため、「観測エ