future

1熱

2答えて

私は現在、Scala/Play2フレームワーク/ MongoDB（reactivemongo）を使用しています私はリクエストで次のような機能を持っています：コレクション内の最大値を見つけ、その最大値をランダムに増やして保存しますそのコレクションの新しい値を返し、新しい値を返します。 def generateCode():Future[String] = { // find maximu

0熱

2答えて

ThreadPoolExecutor特定のタスクが待ち行列に入っているかどうかを確認します

私はシリアル接続を1つのスレッドだけが使用します。しかし、エグゼクティブに新しいタスクを提出する前に、特定のタスクがすでにキューに入っているかどうかチェックしたい（たとえばポーリング値）。 executor = (ThreadPoolExecutor) Executors.newFixedThreadPool(1); new Thread(new Runnable() { @Ove

0熱

1答えて

Scala Play将来の相互依存性

私は自分のscalaにplay-slickを使用しています。Play！ダミーレストAPI。したがって、複数のテーブルからレコードをフェッチする必要があります。しかし、彼らは、私がTABLE_1からレコードをフェッチし、その後ID2がTable_2からフェッチ使用する必要がTable_2からレコードを取得するために、すなわち Table_1 Table_2 id1 id2 id2 相互に

1熱

1答えて

テンプレートできませんでした<typename>ポインタタイプを推測しますか？

私は、何の問題、+が実行次のプログラムをコンパイルしていない #include <thread> #include <future> #include <iostream> #include <algorithm> void f(int* first, int* last, std::promise<int> accumulate_promise) {

2熱

1答えて

isDoneでポーリングを使用し、キャンセルするのではなくJava Futureでキャンセルする

私はリファクタリングできないレガシーコードを作成しています。このコードでは、Java Futureのブロックを使用しています。これはfuture.get（withTimeOut、...）を使用します。これは、適切なサイズのスレッドプールを十分に応答させる必要があることを意味します。コールが終了するか、タイムアウトするまでブロックされます。質問：私は未来をつかんで、それをタスクの実行の開始を認

2熱

2答えて

スカラ先物順次怠惰実行

私はの先物を持っていますが、それぞれは次のような配列を返します。Iterable[Future[Seq[Int]]]結果として、先物から返された配列の連結である配列が必要です。Seq[Int]。事は、私は配列のみを結果の最初のn要素を必要とするので、私は常にすべての先物を実行する必要がないことです。私はまた、それを達成するためにいくつの先物が実行される必要があるかを事前に知っていません（おそらく

0熱

1答えて

将来のFinagleでのリクエストの無限シーケンス

私は常に新しい値をチェックする必要があるHTTP APIエンドポイントを持っています。幸いにも、それは長いポーリングをサポートしています。つまり、私はリクエストを行い、応答を待つ（最大10分）、レスポンスからいくらかの価値を得て、どこかに格納して別のリクエストをして副作用を生むという「無限ループ」を実装する必要があるということです。私はいくつかの関数を持っているので、呼び出しは '無限ループ'を

5熱

4答えて

未来[B =>未来[C]）関数を使用して[A、B]〜未来[A、C]のいずれかです。

Future[Either[A, B]]とBからFuture[C]を提供する関数があります。 Future[Either[A, B]]をFuture[Either[A, C]]に変換する必要があります。 Future[Either[A, C]]を入手する直接の方法はありますが、Future[Either[A, Future[C]]]はありませんか？私のようなものを考えている： val event

3熱

1答えて

今後のレスポンスを解析する際に、何が間違っていますか？

私はajaxリクエストを介してトークンを取得する関数を持っています。トークンが有効である間、ディレクトリのリストに対する応答を返します。 def all = Action.async(parse.json) { implicit request => tokenForm.bind(request.body).fold( formWithErrors => Future.succe