future

    1

    1答えて

    こんにちは、私は、Apacheラクダで作業を開始だし、それが可能このようラクダを使用する場合、私は疑問に思う: 一部のサービス(豆): public class SomeService { public Future<Data> someMethod() { //Do async job } } RouteBuilder擬似構成: public class M

    1

    1答えて

    私はPromiseの最適な実装に興味があり、ブール値の結果を与えることを意図しています。私の質問は、Promises/A+のようにthenの論理的に等価なものを含む約束/先物の実装を考慮します。 私の質問です:そのような約束resolveは結果が何であれ、それはresolvetrueとrejectの上にfalseに何かをする必要がありますか? ES6のようにJavaScriptでこのように : c

    15

    1答えて

    私はstd::variant, lambdasとstd::futureで遊んでいて、それらを一緒に合成しようとしたときに非常に奇妙な結果を得ました。ここでの例は以下のとおりです。 Error C2665 'std::variant<std::function<std::future<void> (int)>,std::function<void (int)>>::variant': none of

    1

    2答えて

    import cats.Monad import cats.instances.future._ import scala.concurrent._ import scala.concurrent.duration._ import scala.concurrent.ExecutionContext.Implicits.global val fm = Monad[Future]

    2

    2答えて

    私はすべてがリモートサービスコール(REST、RPCなど)を行う未来を理解しています。それらの未来のうちの1つが失敗すれば、全体の理解は失敗するでしょうか? たとえば、のは、私はサービスが val service1Future: Future[Response] = ... val service2Future: Future[Response] = ... はのはservice2Futur

    0

    1答えて

    チェーン条件付き俳優今、俳優A型Try[AbcResponse]の応答を返します。 AbcResponseはここのケースクラスです。いくつかのロジックに基づいて 俳優Aは、直接このレスポンスを返すことがありますか、それは条件付きで頼む使用して別のアクターBを呼ぶかもしれません。 Bからの応答を操作した後、それがコントローラにタイプTry[AbcResponse]の応答を送信することになります。 だ

    3

    2答えて

    私のプロジェクトでは、n秒ごとにデバイスをポーリングしてスリープして永遠に続ける必要があります。 std::threadの代わりにasyncとして起動して非同期タスクを作成しました。しかし、私がstd::this_thread::sleep_for()を非同期タスクとして使用して、非同期として起動すると、実際にメインスレッドがブロックされているように見えますか? 以下のプログラムは "Inside

    0

    1答えて

    Rパッケージfuture(非同期計算をサポート)を使用して、ジョブをキューに動的に追加または削除できるクラスタ・ジョブ・サーバーを作成します。 ジョブサーバに追加したい特定の機能の1つは、クラスタ内のより強力なマシンにメモリを要求するジョブを配布することです。しかし、私はパッケージに関する経験がないので、私のアプローチ(下記)に落とし穴があるかどうかは不明です。具体的には、その後の​​の呼び出しに

    2

    2答えて

    typingモジュールをPython 3で使用して非常にうれしく思います。またtwisted,tornadoと代替の代わりにasyncioを使用して非常にうれしく思います。 私の質問は、正しくどのようにコルーチンの結果を定義するのですか? コルーチンであると言わなければなりませんか?例1: async def request() -> asyncio.Future: pass また、