concurrency

    0

    1答えて

    def resolve(url: String): Future[WSResponse] = ws.url(url).withFollowRedirects(true).get() def validateAllLinks(links: List[String]) = ??? どのように2番目の機能を解決しますか? def validateAllLinks(links: List[Stri

    1

    2答えて

    私はこのような機能を持っていると仮定します。 import scala.concurrent._ def plus2Future(fut: Future[Int]) (implicit ec: ExecutionContext): Future[Int] = fut.map(_ + 2) は今、私は新しいFutureを作成するplus2Futureを使用しています: imp

    -1

    1答えて

    定期的にクーポンコードのサイトをスクラップして検証し、通知を送信する必要があります。しかし、検証は遅いので、私はそのプロセスが私のアプリの流れを駄目にしたくない。理想的には、スクレーパーは、より多くの結果を出力するために検証が完了するのを待つ必要はありません。 私はこのように見えるデータの流れを想像: SCRAPER --> \_/ <--> VALIDATOR <--> \_/ <--> NOT

    0

    1答えて

    Retrofit2を使用して、マップ上で選択された特定の場所の情報を取得し、アプリケーションのUIに表示する方法はgetLabelFromServerです。 サーバーから情報を受信するのを待っている間にユーザーが選択した場所を変更する可能性があるため、受信した情報の前回の呼び出しをキャンセルし、新しい場所の情報を受け取り、新しい呼び出しの応答時にUIを更新します。 以前の呼び出しでは、ユーザーが現

    1

    1答えて

    更新:要するに 、私はサービスへのユーザーからメッセージを送信キューを持っています。 しかし、1つのサービスが1000sのメッセージを受け取ると、キューは によって支配され、それ以外のサービスはキューが空になるまでメッセージを受信しません。私はこれを解決するために のアプローチが必要です。 BlockingQueue'sに問題があります。私はそれらにメッセージを配信する責任がある100の外部サービ

    0

    1答えて

    私はgoroutineとして関数を呼び出し、WaitGroupを使用して共用スキャナがすべて終了する前に閉じないようにします。 myfunc()関数はファイルに対して反復処理を行います。私は、このファイルをメモリマップでマップし、毎回ディスクから読み込むというI/Oチョークポイントを持つのではなく、すべてのゴルーチン間で共有したかったのです。私はこのアプローチがうまくいくと言われましたin an

    0

    2答えて

    私はこの簡単なプログラムを使って、ThreadPoolとExecutorServiceを使って1から9までの数を数えます。 各スレッドは実行に1秒間待機しています。しかし、以下のプログラムでは、実行ごとにランダムな出力が得られます。 これを修正する方法がわからず、常に45を生成します。 助けてください! public static void main(String[] args) throws I