future

    0

    2答えて

    私は未来の操作を提出するオブジェクトと関数を取得するFuture Lazy Valを持っています。 class C { def printLn(s: String) = println(s) } lazy val futureC: Future[C] = Future{Thread.sleep(3000); new C()} def func(s: String): Unit =

    0

    1答えて

    私はスカラ座に新しいですし、私は先物のハンドルを取得しようと、私は行列 SingleThreadCalc { def run(matrix : Seq[Seq[Double]]) : Future[Seq[Seq[Double]] = Future{doMath(matrix)} } 上のいくつかの計算を行い、プログラムのSingleThreadedバージョンを持っている をマルチ

    0

    1答えて

    をMYTYPEする[未来【がMyType]、問題のように基本的な署名がある: val a: Seq[Future[MyType]] = ... getValue(t: MyType): Seq[Future[MyType]] = {...} getValueにaの値を渡したいと思います。 [がMyType]タイプの未来であるとのgetValueパラメータとしてのみがMyTypeを必要と私は

    1

    1答えて

    次の例では、予想される動作は何ですか? import scala.concurrent.ExecutionContext.Implicits.global val someFuture = Future { 1+1 }.map(elem => { println("mapping immediately") elem.toString }) someFuture.onC

    2

    2答えて

    大きなテキストファイルを受け取るクラスを実装しています。私はそれを塊で分割し、各塊をこの塊の各文字の頻度を数える別のスレッドによって保持したいと思っています。より多くのスレッドを起動してパフォーマンスを向上させることが期待されますが、パフォーマンスが低下していることが判明しました。 Here`s私のコード: public class Main { public static void

    0

    1答えて

    web3jライブラリを使用して、Ethereumブロックチェーン用にJavaで負荷テストアプリケーションを開発しています。このライブラリから使用される特定の関数は、トランザクションを非同期に送信し、Futureオブジェクトを返します。そのライブラリは、アプリケーションの開発のために私が最初に必要としていた多くの機能を提供します。しかし、負荷テストアプリケーションを設計して再設計した後、私は問題に気

    0

    1答えて

    私は、Actorモデルを使用してバックグラウンドプロセスを管理するための単純なオブジェクトセットを持っています。この場合、私は1人の俳優にしか関心がありません。ただし、アクターがメッセージを受信する間は永続的な状態を維持することが重要です。 オブジェクトは、メインスレッドのキューにメッセージを追加することで機能します。それから、メインスレッドは気に入ったように実行できます。しばらくして、結果キュー

    1

    2答えて

    を知らなければなら全く私のコードで間違って何: 私はいくつかのFutureを持っています例外をスローすることがあります。私はタイトルに指定されたエラーをコンパイル取得 clean.map(b => { case true => Ok("success") case false => Ok("failed") }).recover { case t => Ok("er

    0

    2答えて

    私は、FutureBuilderクラスを構築し、連鎖先物をシンプルにするというアイディアを持っています。このプロセスで私はAwaitを使用することの結果を理解しようとしています。 だから私はこの F1(future1)のような何かを行くマッパーを使用している場合 - > F2 - > F3 F1:オブジェクトはFoo F2を構築します:に値バーを追加するDBへ行きますFooの F3:どこかにはFo

    2

    1答えて

    私はandThenメソッドを使用して将来のアクションステージを登録しようとしています。このように: implicit val executionContext = ExecutionContext.global val f = Future(0) f.andThen { case r => println(r.get + "1") } andThen { case r