future

1熱

2答えて

複雑な浮動小数点の2つのベクトルを乗算し、その結果を合計するコードを並列化しようとしています。これを行うには、私は先物を使ってstd :: asyncを使用しようとしています。私の考えは、ベクトルを8つの部分に分割し、これら8つの部分のそれぞれを並列に乗算してから最終結果を得ることでした。これを行うには、2つのベクトルを乗算して結果を合計するラムダを含む8つの先物を作成します。それぞれの未来は、こ

1熱

1答えて

Akka先物のセットを管理する方法

私は、私が書いている図書館のための単一のオブジェクトに管理したいFuture [T]のセットを持っています。私の現在の実装では、Future.sequenceを使用してそれらをすべて収集し、解決するまで待っているので、未来のことを行うことができます（マップ、収集、フィルター）。しかし、これは私に、成功または失敗にマッチする能力を与えるだけです。これは、私が扱っている先物の収集のためのケースではあり

1熱

1答えて

一連の先物によるスキャラキャッチスクロール

未来のリストを与えられたすべてのエラーを非同期的にキャッチすることは可能ですか？私のようなものを考えていた： Future { throw Exception } zip Future { throw Exception } recover ... しかし、私は唯一の回復部分でのThrowableを受けます。何か案が？

2熱

2答えて

並行実行：未来対並行

私は、情報のためにリモートクライアントをポーリングし、その情報をリスト形式で返す呼び出し可能コードを書きました。私はthreadpoolexecutor forループを使い、Futureは複数のリモートクライアントに対して並列にタスクを実行しています。それから、私は将来のリストをすべてaddAll（）と組み合わせ、巨大な結合リストを扱います。私の質問は、parallelstream（）を将来のル

2熱

1答えて

Flattening List + Scalaの未来

私はこのようなファンキーな構造を待っています：Future[List[Future[List[Object]]]]。一番外側の未来を取り除くことを待っていますが、これをトリミングのきれいな方法で簡単にList[Object]にしていますか？ Future.sequence使用

3熱

1答えて

未来が始まるかどうかを知る

私はopenejbと非同期EJBを使用しています。私は先物がたくさんあり、先物の1つに時間がかかりすぎるかどうかを知りたい（私はそれをトレースして最終的に取り消すことができます）。問題は、将来のsiがどれくらいの期間実行されているかを知るためには、いつ開始するのかを知る必要があるということです。未来のインターフェイスは、未来が終了したかキャンセルされたかを教えてくれますが、そうでなければ、プール

1熱

1答えて

スカラ先物 - どのスレッドがonCompleteを実行しますか？ジェイソン・グッドウィン学習アッカで

は私が読んで：それはイベントを登録したスレッド上で実行されません再び-print文を強調することが重要です val future = getUsernameFromDatabaseAsync(userId) future.onComplete(username => //executed somewhere else println(username) ) 。 Exec

2熱

2答えて

将来のエラーから例外を処理できません

メソッドの1つがcallfuture1()またはcallfuture2()の場合に例外をスローすると、次のコードでカスタムメッセージを返すようにします。将来のどちらかが失敗した場合、私の理解は、fが失敗した未来になるでしょう。ただし、callfuture1が例外をスローした場合。 f.onFailureは実行されません。代わりに、例外の発生した標準のinternalErrorが返されるcallF

5熱

1答えて

すべてのstd :: futuresが終了する前に関数から戻っても安全ですか？

私はそのようなコードを持っているが： int function() { std::vector<std::future<int>> futures; for (const auto& elem : elements) { futures.push_back(std::async(&MyClass::foo, myClass, elem); }

1熱

1答えて

get（）が呼び出されても未来が実行されない

systemの呼び出しを並列に実行したいが、f1.get()を呼び出しても、以下の行の対処は行われない。このコードで何が問題になっていますか？ auto f1 = std::async(system, string("cp a b").c_str()); f1.get(); // there is still no file "b". 注：私は、私は別の文字列から一緒に引数を入れて使用してい