future

2熱

1答えて

に将来のタイムスタンプを挿入するにはどうすればよい私は、この例ではselectを参照してください、私はこのようなクエリ実行しようとする場合： INSERT INTO "public"."sessions"("account", "token_key", "timestamp", "timeout") VALUES('[email protected]', 'afasdfasdf', 'now()'

2熱

1答えて

スカラでDAGのような操作を実行するFuture

私はscala Futureを使用して相互依存操作（Directed Acyclic Graphとして定義）を実行する必要があるユースケースに取り組んでいます。基本的にはすべての操作（DAGのノード）がFutureで実行され、現在のノードFutureが完了すると、後続の依存ノードがトリガされます（Futureにも存在するはずです）。これは、すべてのノードが処理を終了するか、いずれかが失敗するまで続

0熱

2答えて

Scala Future.failedは、渡された例外をスローします

私はFuture.failedコンストラクタを使用して失敗した未来を作成していますが、失敗した未来は、 session.loadAllメソッドは例外をスローします。また、私はそれも

7熱

1答えて

は、私は私の実際のプロジェクトでは、この問題が発生したため、私のテストコードとプロファイラによって証明しましたメカニズム

を収集します。「tl; dr」コードを貼り付ける代わりに、私はあなたに絵を見せて、それを説明します。簡単に言えば、私は共有のものを持っていないし、お互いを気にしない、どちらも、2 Future sから結果を得るためにFuture.firstCompletedOfを使用しています。私が対処したい質問であっても、Futureの両方が完了するまで、ガベージコレクタは最初のResultオブジェクトをリ

0熱

1答えて

C++非同期セグメントエラー

次のコードを書きました。セグメント・フォールト:: 11 をしかし、時にはません：それは時々なります。理由を説明できますか？私は次の質問についても興味があります。一般的に、C++はスレッドに/をどのように割り当てますか？launch::asyncとlaunch::defferredの機能はどのように実行されますか？ std::waitの不都合はstd::getの場合はfuture<void>

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