future

0熱

1答えて

Akka-Javaは依頼待ちでDeadLetterExceptionをスローしています

私はこのようなファイルにドライバ/メインクラスを持っています。 （基本的に私はSTORM & AKKAを混ぜようとしています）。 TenderEventSpout2クラスでは、俳優との間でメッセージの送受信をしようとしています。 public class TenderEventSpout2 extends BaseRichSpout { ActorSystemHandle actorS

java akka future dead-letter 2016-05-12

---

1熱

1答えて

処理の例外は、次のコードでの例外処理についてグアバ

で先物を連鎖するとき： ListenableFuture<BufferedImage> imgFuture = downloadExecutor .submit(new Downloader(url)); ListenableFuture<BufferedImage> resizeFuture = Futures.transformAsync( im

java concurrency guava future 2016-05-17

---

0熱

1答えて

竜巻の将来のオブジェクトからコンテンツを取得する方法

私は本当に竜巻フレームの仕事と '未来'のオブジェクトで混乱しています。 だから私はあるHTTP呼び出し コードを作成することにより、非同期応答を取得したい：私はこの1つを終えた後の事は、私はそれをテストすることができ、どのように、ある class TestAsyncHttp(object): def __init__(self): self._http_client = h

python http asynchronous tornado future 2016-05-18

---

0熱

1答えて

C++スレッドとプロミス：削除された関数を参照しようとしています

私はオンラインで見つかったこの例を実行する際にいくつか問題があります。 void asyncFun(std::promise<int> intPromise) { int result=5; try { // calculate the result intPromise.set_value(result); } catch (...

c++ multithreading promise future 2016-05-18

---

4熱

2答えて

ブロッキングなしでJava 8で依存するタスクを実行する方法

私はこの質問に答えました：Executing Dependent tasks in parallel in Java future.get（）を使用して現在のスレッドをブロックしています。一度にたくさんのgets（）が呼び出されます。 Javaの先物から先物をどのように構成するのですか？

java multithreading future 2016-05-25

---

0熱

2答えて

私はPredef識別機能をいじり先物とこの表現になった先物

使用してScalaのアイデンティティコールを理解することはできませんよ。 identity(_: Future[A]) これはFuture[A] => Future[A]を返しますが、私はちょうどFuture[A] を期待していたがアイデンティティメソッドはちょうど正確に_: Future[A]を意味するのだろうかと思うので、入力を返します。

scala future 2016-05-27

---

0熱

1答えて

Python BadYieldError When future yield

私はコルーチンを使ってプログラミングするのが新しく、Python 2.7.10を使用してTornado Webサーバーのカスタムデータベースのデータベースインターフェイスを構築しようとしています。しかし、私はBadYieldErrorを得続けます。 tornado.gen.coroutineをPythonのyieldで完全に使用する方法を理解していないのではないかと思います。私は未来を生み出す方法

python tornado future yield coroutine 2016-05-31

---

1熱

1答えて

ネストされたScala先物にマネージブロックが必要ですか？

新しいスレッドを割り当てることができる私のfork-join-pool（デフォルトのグローバル）の場合、Nested Futuresがある場合、DBコールの場合、個々のFuturesを{...}ブロックでラップする必要がありますまたは他のI/O /ネットワークプロセスなどがありますか？ どちらが正しいですか？ Future.sequence( blocking{ val f1

java scala concurrency akka future 2016-05-31

---

0熱

2答えて

URLをフェッチするために竜巻の未来を使用する、2つの異なる方法は異なる結果を得る

私はバネのURLを取得するために竜巻を使いたい。だから私のコードは以下を示しています。 ERROR:tornado.application:Exception in callback <function f_callback at 0x7f35458cae60> for <tornado.concurrent.Future object at 0x7f35458c9650> Traceback

python tornado future 2016-06-01

---