future

0熱

1答えて

Scala Futuresに問題があります。 x：Future [Int]とy：Future [Int]という2つのパラメータを取る関数があります。関数がで完了未来を返す必要があります。xの値、yのxが正常に完了した場合、値xが失敗し、yが正常に完了した場合、 yは失敗した例外xが失敗し、yが失敗した場合私はこれを行う方法を理解できないようです。現在コード：単に def myFuncti

0熱

1答えて

http接続が長い間開いていないときにAsyncResultを使用する

古いリバースプロキシ（接続ごとのスレッドモデル）が原因で、クライアント接続を長く開いたままにすることはできません。ブラウザリクエストで、処理に3分かかる非同期EJBメソッドが呼び出されたとします。返されたFutureを引き続き利用できますか？私はそれをどこか別の場所に保管して、異なる要求にアクセスできるようにする必要がありますか？この問題を解決するにはどうすればよいでしょうか？

0熱

2答えて

2つ目のExecutionContextを持たないコールバック付きスカラ先生2つを作成する

私は2つの方法を持っています。それらをload()とinit()と呼びましょう。それぞれは独自のスレッドで計算を開始し、独自の実行コンテキストでFutureを返します。 2つの計算は独立しています。それはmain()からだと言う - - との両方が終了したら、他のいくつかの計算を実行 val loadContext = ExecutionContext.fromExecutor(...) def

0熱

2答えて

スカラ：ファイルデータのシーケンシャル処理

私はデータを読み込んでデータベースを作成するcsvファイルを持っています。私はこれを行うためにスカラを使用しています。 dbインサートを並行して実行するのではなく、インサートを順番に（つまり、順番に）実行したいと考えています。 forループでAwaitを使用するつもりはありません。待っている以外の方法はありますか？ PS：私は、CSVファイルからリストに1000個のエントリを読んで、DBを作成する

0熱

1答えて

Springバッチ：非同期アイテムプロセッサを使用中に書き込みエラーリスナーで実際のアイテムを取得する

アプリケーションの背景：私は非同期アイテムプロセッサを使用しており、コンポジットプロセッサとして代理人を渡しています。プロセッサーで例外が発生すると、書き込みエラーリスナーが呼び出されます。 onWriteErrorメソッドシグネチャ（例外例外、リストアイテム）問題です：onWriteError方法にリスト上のすべての項目が今後の課題です。私は、将来のタスクで "get"メソッドを呼び出す場

9熱

3答えて

ExecutorService Futureなぜ<?> submit（実行可能タスク）？

には、以下の方法があります。 Future<?> submit(Runnable task) をしかし、このFutureのgetメソッドは常にnullを返しますので、以下の署名は、より適切なのではないでしょうか？ Future<Void> submit(Runnable task)

1熱

2答えて

先物変換のための流暢な構文

私はGuava Futuresを使用して、将来の呼び出しを連鎖させます。特に私はFutures.transform(...)とFutures.transformAsync(...)の構成を使用していますが、結果のコードはあまり読みにくくありません。同じことをより流暢に表現する方法はありますか？

1熱

1答えて

Scalaz 7でEitherTを使用するときのMonad [Future]の実行コンテキストの指定

私はFuture [Either [String、A]]型を返す複数の関数を使用するコードを整理しようとしています。これらの関数は、未来の中でピークを迎えなければならないという問題と、値を取得するためにEitherの内部で問題が発生するため、きれいには構成されません。 EitherTモナドトランスを使用した後、私は、どちらかを追加する必要があり、最終結果を得るときに '実行'を呼び出す余分なステ