future

1熱度

1回答

我實現了一個簡單的ListActivity自定義ArrayAdapter。該佈局包含一個ImageView和一個TextView。在自定義適配器的getView方法中，我啓動未來以在所需位置同時下載圖像。現在，當我快速滾動列表時，應用程序將崩潰，因爲它會產生太多下載工作線程，並最終耗盡內存。幾乎所有觸發的工作線程都會下載圖像，以便再次丟棄它，因爲觸發的ImageView將在當時被重用，並且只有少

1熱度

1回答

如何使用Future訪問數據庫

我在混合Java/Scala程序中使用slick。 Java代碼需要從數據庫中獲取一些數據。據我所知，推薦的方法是從數據庫中獲取Future，但我該如何從這裏開始？我是否被迫等待結果（使用阻塞Await.result）？我可以通過onComplete使Java的行爲與Scala類似嗎？電流（阻塞）代碼：光滑[斯卡拉]： def getUser(email: String): Option[U

5熱度

1回答

阻斷對ListenableFuture與超時

我使用Spring 4.2.3 AsyncRestTemplate.exchange（）調用一些API，將採取幾秒鐘，我期待的是listenableFuture.get（1，TimeUnit.SECONDS）將塊1秒，然後拋出TimeOutException。代替會發生什麼情況是，listenableFuture.get（）將API調用的整個時間（超過1秒）塊 AsyncRestTemplate

1熱度

1回答

如何通過內部函數將異常返回到Action函數？

我有一個簡單的動作功能： def someActionFunc() = Action.async { request => myService.doSomething1().map { res => logger.debug(res.getMessageId) Ok(res.getMessageId) }.recover { case ex =>

0熱度

2回答

爲什麼我的地圖（）不工作？

我有它返回一個字符串，如下所示的阿卡HTTP服務： val route1: Route = { path("hello") { get{ complete{ println("Inside r1") "You just accessed hello" } } } } 我想了解地圖和flatMap

2熱度

2回答

如何轉變一個HashMap [T，未來[N]到未來[HashMap的[T，N]

我知道存在 Future.sequence 來變換List[Future[T]]到Future[List[T]] 有沒有辦法將HashMap[T,Future[N]]改成Future[HashMap[T,N]]？

3熱度

1回答

Dart未來的功能，請求回調

我有一個理解飛鏢和異步編程的未來功能的問題。我在網上找到的例子沒有回答我的問題，所以我會很感激社區的幫助。我有要求的玩家消息列表功能： Future getMessagesInfo(response) async{ dialogs = []; // I need this list to be filled to proceed messagesList = respon

4熱度

1回答

如何捕獲CompletableFuture的whenCompleteAsync調用中拋出的RejectedExecutionException？

下面的示例代碼我正在注入一個biconsumer睡眠100毫米作爲一套完整的未來的完成行動。我已經使用whenCompleteAsync方法，通過單獨使用executorService。 executorService是ThreadPoolExecutor與芯池大小5，最大尺寸和5 1. public class CompleteTest { public static void mai

0熱度

2回答

斯卡拉 - 如何使用期貨發送異常情況下的失敗響應

我正在處理一個我希望成爲非阻塞的端點。此端點的目的非常簡單，即向Mongo商店寫入文檔。我在Play 2.5.x應用中使用官方MongoDB Scala Driver。我的理解是，MongoDB支持期貨使用toFuture()方法。 Source 問題是我的控制器中的處理方法期望解析爲類型Future[Result]。但是，onComplete回調（或其他回調函數）僅返回類型Unit，導致編譯錯

0熱度

1回答

Java Spark：CompletableFutures的非阻塞路由/回調

我必須在Spark API實現中調用長時間運行的方法。這些方法返回CompletableFutures，所以我想通過觸發Spark在回調中回答客戶端請求來釋放當前的線程。據我可以告訴這是不可能與Spark，但我想確保我不俯瞰任何東西。爲了說明這個問題，請參閱下面的小代碼示例。 import spark.Spark; import java.util.concurrent.Completabl