future

0熱

1答えて

コードはここにある： https://github.com/ReactiveX/RxPY/blob/master/examples/autocomplete/autocomplete_asyncio.py#L63 searcher = query.flat_map_latest(search_wikipedia) def search_wikipedia(term): """Sear

5熱

2答えて

Vert.x java List <Futures>パラメータ化

先日、Vert.x先物で奇妙な問題が発生しましたが、コードを壊すことはありませんが、まだ気になります。次の警告のパラメータ結果なし未来：今後は、生タイプです。ジェネリック型の未来への参照パラメータを追加しますパラメータ化する必要があり、問題が解決： Future<YourClassName> future = ... 先物のリストを扱うとき、あなたはまた、うまくそれをパラメータ化すること

1熱

1答えて

foreachPartitionAsync throwsは停止したSparkContextのメソッドを呼び出せません

私は異なるデータを持つ2つのファイルを持っています。私は2 diff RDDs &でそれらを読み取ろうとしているとデータフレーム&ハイブに挿入するに変換します。私はこの通常のコードを実行することができました。だから、2番目の人はクラスターに十分なリソースがあるのに、1番目が乗り越えるのを待っていました。私は、RDD計算がAsyncメソッドを使って並列化できることを学びました。だからforeachP

0熱

1答えて

スカラ先物のスレッド間で値が転送される方法

新しいスレッドがnumにアクセスする方法を教えてください。未来は新しいスレッドで実行されます。メインスレッドのスタックフレームにあるnumの値は、新しいスレッドでどのようにアクセス可能ですか？それはどこに保管されていますか？ object TestFutureActor extends App { var num = 10 val addNum = Future {

0熱

1答えて

次のスクリプトのコールバック関数がなぜ呼び出されないのですか？

次のスクリプトで、私のコールバック関数が呼び出されないのはなぜですか？コードを実行し、それぞれのソケットのコールバックを添付して出力を取得しようとすると、あらかじめ作成されたカーネルを使用しています。ここで from zmq.eventloop import ioloop ioloop.install() from zmq.eventloop.zmqstream import ZMQStre

2熱

1答えて

ExecutorService Future ::非常に遅い

私はそれをより速くするために非常に複雑なプログラムを並列化しています。このために私はほとんどの時間をExecutorServiceで使います。これまではかなりうまくいっていましたが、コードのほんの1行でプログラムが半分の速さで実行されることに気付きました。 exactScore.get()の行です。私は理由はわかりませんが、未来オブジェクトの2倍の値を取得するために0.1秒以上かかることがありま

2熱

2答えて

Scala：いくつかのタイムアウトが発生したときに、先物リストの結果を集めるには？

この状況での私の練習は.sequenceを使ってF[G[A]]をG[F[A]]に変えることです。次に、Await.result(future_of_a_list, time_out)を使用して結果を取得します。しかし、長い時間と時間を要するタスクがあるかもしれません。この場合、残りの結果を（すべてのタスクを並行して実行しながら）得たいです。出来ますか？どうやってするの？おかげ

3熱

3答えて

Java Futureはいつもnullを返す

こんにちは私はJava Futuresについて簡単に質問しました。私はこのスニペットに問題が決裂： ExecutorService service = Executors.newCachedThreadPool(); try { System.out.println(service.submit(new FutureTask<>(() -> true)).get());

1熱

2答えて

待つことなく未来の状態をポーリングする方法？

私はFuture.rsを使用して、別のプロセスでいくつかのタスクを管理しようとしています。私は、それぞれの未来を待つ方法と、それを次々に処理する方法を見ていますが、その状態を知るために実行中の未来をポーリングすることはできませんでした。私はいつもエラーがあります： thread 'main' panicked at 'no Task is currently running' 私はいつもそれが完了

0熱

2答えて

"await"を使わずにFutureの結果を得るには

私は未来の結果をブロック操作なしで得たいと思っています。私は「待つ」との私のコードを記述する場合、それは動作しますが、それがブロックしているので、それは私のために良いではありません。 val t: Future[MatchResult[Personne]] = db.getPersonne(userId).map(_.get must beEqualTo(personne)) t.await