future

1熱度

1回答

Ajax響應等待未來（scala）

如果我在路由器的後（「/ some」）路徑中有Future [A]作爲結果（最後一行），Ajax客戶端無法獲得響應並且超過時間到。等待不起作用。未來onComplete/onSuccess {...}工作正常，但對於服務器，所以如何將它翻譯爲客戶端作爲響應？ （Scalatra的框架） 服務器： post("/stations/test") { Future[Int] { //

ajax scala future scalatra 2016-09-17

---

2熱度

1回答

ThreadPoolExecutor，Futures：關聯請求和響應

我試圖使用ThreadPoolExecutor以及Future（結果）和Callable（要執行的任務），但我找不到一個簡單的方法來關聯輸入（Callable）與相應的結果（未來），似乎唯一明智的方法是創建一個包含所有項目的包裝器（example），但這對於這樣一個簡單的任務可能會造成太多開銷。 我錯了嗎？任何建議的選擇？

java multithreading threadpool future threadpoolexecutor 2016-09-20

---

0熱度

1回答

複雜的未來unwraping

我知道我可以解開 Future[Future[Seq]] => Future[Seq] 隨着flatMap功能 但我怎麼得到下面的映射？ Future[Seq[Future[Seq]]] => Future[Seq[Seq]]

scala future 2016-09-29

---

0熱度

2回答

C++稍後從線程函數中獲取返回值

是否有可能不等待來自線程函數的返回值？例如稍後檢查值是否曾經返回，並在該函數執行時執行其他操作？我的意思是，如果你不得不等待函數返回，那麼它就不是真正的多線程，因爲你可以直接調用函數。 #include <thread> #include <future> int func_1(int x) { return x; //Assume this takes several seco

c++ multithreading return future 2016-09-30

---

2熱度

2回答

如何在Java 8中多次使用thenCompose的結果？

我有一系列的thenCompose通話，類似於 myObject.updateDB(payload) .thenCompose(__ -> getUserID(payload.ID())) .thenCompose(id -> getProfile(id)) .thenCompose(userProfile -> updateSomething(userProf

java java-8 future completable-future 2016-10-02

---

30熱度

4回答

在C中的等價承諾＃

在斯卡拉有一個Promise類，可以用來手動完成一個Future。我正在尋找在C＃中的替代品。 我寫一個測試，我希望它看起來就與此類似： // var MyResult has a field `Header` var promise = new Promise<MyResult>; handlerMyEventsWithHandler(msg => promise.Complet

c# promise async-await task future 2016-08-17

---

0熱度

1回答

如何使用理解來表達以下嵌套式期貨

我的問題：是否可以使用for-comprehension簡化這種嵌套式表達式？ run(dbAction).flatMap(insertedJobs => { Future.sequence(insertedJobs.map { job => recordingBean.findStreamsForInterval(job.mediaSource, job.begin, job

scala for-loop dictionary future flatmap 2016-08-18

---

1熱度

1回答

從Scala未來完成中返回價值

從Java背景來看，我一直在嘗試自學Scala一段時間。作爲其中的一部分，我正在做一個小型寵物項目，公開一個HTTP端點，將一輛車的registration number與owner對接並返回狀態。 爲了給出更多的上下文，我使用Slick作爲FRM，它異步執行數據庫操作並返回Future。 根據這個Future的輸出，我想設置status變量返回給客戶端。 這裏，是代碼 def addVehicl

scala functional-programming slick future 2016-10-10

---

0熱度

1回答

將承諾鏈接到另一個

我在閱讀scala.concurrent.impl.Promise，並被「將DefaultPromise與另一個鏈接」概念混淆。我理解'防止內存泄漏'部分，但不知道如何編寫一個示例，其中DefaultPromise的當前狀態爲DefaultPromise。 當第一次創建DefaultPromise時，其狀態爲Nil，並且該列表隨着我們繼續追加flatMap而增加。在什麼情況下分支 case dp:

scala promise future 2016-08-24

---

0熱度

1回答

覆蓋RootMonitor

我在Future.respond中運行了一些代碼，由於一個錯誤，它會拋出一個NPE。問題是我的單元測試完全錯過了它，並且都非常高興地通過，因爲NPE被RootMonitor吞噬了。 所以，我的問題是，如果有任何方式來覆蓋單元測試的RootMonitor行爲導致測試失敗而不是吞嚥異常？ 我知道，我可以在響應中捕獲異常，但這有點不好 - 如果我認爲可能會有異常，我會首先解決它。這正是我希望我的測試能夠

scala future finagle twitter-finagle 2016-09-06

---