future

1熱度

1回答

我對Promise的最佳實現感興趣，這是爲了給出布爾結果。我的問題認爲承諾/期貨的任何實施都包含then的邏輯等價物，如Promises/A+。我的問題是：應該這樣一個承諾resolve用布爾值無論結果或resolvetrue和reject在false？在Javascript 因此在ES6： class Named { constructor(name) { this.na

15熱度

1回答

無法初始化各種lambda表達式的std :: variant

我在玩std::variant, lambdas和std::future，當我試圖將它們組合在一起時，得到了超級奇怪的結果。下面舉例說明： using variant_t = std::variant< std::function<std::future<void>(int)>, std::function<void(int)> >; auto f1 = [](int) {

1熱度

2回答

貓未來Monad給出運行時異常

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等）的期貨。如果其中一個未來失敗，整個理解是否會失敗？舉例來說，假設我有兩個期貨，使服務調用 val service1Future: Future[Response] = ... val service2Future: Future[Response] = ... 假設service2Future也有一些recoverWith拋出異常Partial

0熱度

1回答

Scala：條件演員鏈接

我有兩個演員A和B. 控制器向演員A發送請求。現在演員A返回類型爲Try[AbcResponse]的響應。 AbcResponse這裏是一個案例類。基於某種邏輯的Actor A可能會直接返回此響應，或者可能會使用ask有條件地調用另一個actor B.在操縱B的響應之後，它會將類型爲Try[AbcResponse]的響應發送給控制器。那麼我應該怎樣在我的演員A中處理這種情況。我不想在我的演員A

1熱度

2回答

如何在外部將來在Scala中使用內未來價值

您好我有兩個期貨FutureA和FutureB我想從FutureB取一個值，在FutureA使用它，但所有我得到是空這裏是代碼 futureA = ask(ActorA, MessageA).mapTo[Int] FutureB = ask(ActorB, MessageB).mapTo[Int] var someResult=0 futureA.map {

0熱度

2回答

FutureTask（）調用參照對象，導致錯誤

我想結果是 jsonObject={"key":[2,2,3]} jsonObject={"key":[2,4,3]} jsonObject={"key":[2,4,6]} ，但結果是 {"key":[2,4,6]} {"key":[2,4,6]} {"key":[2,4,6]} 我不知道什麼是錯的。請幫忙。謝謝！如何更改代碼？對象始終是最後一個號碼。代碼： public

0熱度

1回答

通過將來的軟件包在R中執行集羣作業管理

我想使用R軟件包future（支持異步計算）來創建一個可以動態地向/從隊列添加/刪除作業的集羣作業服務器。我想添加到我的作業服務器的一個特定功能是將內存要求較高的作業分配給羣集中功能更強大的機器。然而，由於我對這個軟件包沒有經驗，我不太確定我的方法（下面給出）是否有任何缺陷。具體來說，的後續調用有任何副作用，可能會搞砸了嗎？請參閱代碼中的註釋以獲取更多詳細信息。在此先感謝！ library

1熱度

1回答

順序處理飛鏢中可變數量的異步函數

我需要在Dart中反覆調用異步函數，我們將其稱爲expensiveFunction，以獲取可變數目的參數。但是，由於每次調用都非常耗費內存，所以我不能並行運行它們。我如何強制他們順序運行？我已經試過這樣： argList.forEach(await (int arg) async { Completer c = new Completer(); expensiveFuncti

0熱度

1回答

使用Tornado web框架執行異步任務

我熟悉事件驅動的編程，但是我遇到了這個問題，我終止了可能的解決方案。我讀了龍捲風的文檔，我試着用：期貨 gen.coroutine 異步 add_timeout ，但我沒能解決以下問題：我有一個websocket服務器這只是聽新郵件並根據消息類型調用特定的功能類WebSocketHandler（tornado.websocket.WebSocketHandler）： ... def o