future

0熱

1答えて

私はflatMap機能で Future[Future[Seq]] => Future[Seq] のラップを解除することができます知っているが、どのように私はマッピングを次のですか？ Future[Seq[Future[Seq]]] => Future[Seq[Seq]]

0熱

2答えて

C++スレッド関数から戻り値を後で取得する

スレッド関数から戻り値を待つことはできますか？その値が今までに返されたかどうかをチェックし、その関数が実行されている間に何か他のことをしていますか？私は関数を返すのを待たなければならないのであれば、本当にマルチスレッドではないということです。 #include <thread> #include <future> int func_1(int x) { return x; //A

1熱

3答えて

タスクのキャンセルに失敗した原因は何ですか？

「ブール（ブールmayInterruptIfRunning）をキャンセルこのタスクの実行の取り消しを試みます。タスクはすでにが完了している場合、この試みは失敗します、すでにキャンセルされた、または他の何らかの理由でキャンセルすることができませんでした」上記の理由のほかに https://docs.oracle.com/javase/7/docs/api/java/util/concurren

4熱

3答えて

将来のコールバックメソッドと約束[成功と失敗]の違いは？

私はFutureとPromisesを使用してScala Concurrencyを寄付しています。私はポイントを取得していません。Callbackメソッドを使用して未来を完成させ、約束を使用することの正確な違いは何ですか？未来のコールバックメソッドが実際に未来を完了していないことを意味しますか？プロミスを使用して未来を完成することができますか？また、私は、先物と約束の両方から読むことができるよ

1熱

3答えて

Netty ChannelFutureの仕組みは？

私はNetty Guideを読みましたが、ChannelFutureについてはあまり説明しません。 ChannelFutureは複雑なアイディアです私がしようとしているのは、初期応答後に文脈にメッセージを書き込むことです。一般的な要求/応答フローとは異なります。リクエスト送信クライアント - >サーバー（網状） Serverはctx.writeAndFlush（MSG）との応答を送信する;：私

-3熱

1答えて

Java：未来を追加する<obj>をリストに追加する

オブジェクトを並行して取得することができたので、これらのオブジェクトをリストに追加するにはどうすればよいですか？ ArrayListのSiteオブジェクトに追加しようとしているオブジェクトのリストがあります。Future<Site>ここに私のforループがあります。ループ内にprintステートメントを追加すると、Future<Site>オブジェクトのリストが実際に埋め込まれていることがわかりますが

-1熱

2答えて

SQL：将来の日付をUNIX_TIMESTAMP（）でタイムスタンプに変換する方法は？

DATETIMEを列からUNIXのTIMESTAMPに変換する必要があります。 - > GOOD SELECT UNIX_TIMESTAMP('2036-09-03 09:00:00')戻り2104038000 - > GOOD SELECT UNIX_TIMESTAMP('2016-09-03 09:00:00')戻り1472886000：しかし、事は、2066年9月1日として、これらの日付は、

1熱

1答えて

tornado.concurrent.Future例外で混乱しています

私はthis questionの亜種を実装するために、竜巻先物を使用しています。過去のデータを蓄積したくないので、キューに問題があります。私は、1つのHTTPリクエストハンドラが、オリジナルが開始した後に発生する別のものの結果を待つのをブロックするようにしたい。しかし、私は一歩足りないと思う。何が起こることは、私がどのように見えるエラーが出るということです Events = dict() c

3熱

1答えて

スカラ：SeqからSequential Futuresへ

私はのBookを持っています。私は自分のデータベースにSeqと同じ順序で保存する必要があります。 books.map(_.save) どのように私は順次これらを保存し、実行、しかしFutureとして結果を返すことができます？Book.saveは、私は次のコードを記述する場合、私が知っているセーブ順序は保持されないことがありFuture[Unit] を返しますか。ありがとう！

1熱

1答えて

将来のAjax応答待ち（scala）

ルータのポスト（ "/ some"）パスにFuture [A]が結果（最後の行）としてある場合、Ajaxクライアントは応答を取得できず、aタイムアウト。待つことはできません。将来のonComplete/onSuccess {...}は正常に動作しますが、サーバーに対しては、それをクライアントに応答としてどのように変換するのでしょうか？（Scalatraフレームワーク）サーバー： post("/