future

2熱度

2回答

我希望以下代碼在方法callfuture1()或callfuture2()之一引發異常時返回自定義消息。我的理解是，如果任一未來失敗，f將是一個失敗的未來。但是，當callfuture1引發異常。 f.onFailure未執行。相反，我看到在callFuture1()的代碼行停止了調用堆棧，發生異常並返回了標準的internalError。爲什麼會發生？ val f = for { x <-

0熱度

1回答

問題與並行任務

迭代值我有一個for循環作爲獲得由ThreadPoolExecutor的並列執行多次調用類的一部分。可調用類的其餘部分似乎運行正常。我認爲這很重要。只有迭代器導致問題。所以這裏是411：循環運行，它在分立列表中搜索報警。當它找到一個（它會在我絆倒任何一個時做它），它應該創建一個報警對象並給它在列表中的位置ID。這就是迭代器的用途。直到我使這項任務並行執行，迭代器（int i）以每次返回的數組中它

8熱度

2回答

文檔測試不承認__future __師

我有以下的doctest書面x.doctest： This is something: >>> x = 3 + 4 foo bar something else: >>> from __future__ import division >>> y = 15 >>> z = int('24') >>> m = z/y >>> pri

1熱度

1回答

斯卡拉來自多個未來呼叫的聚合結果

考慮用於羣集的主/從選擇模型。 Member{ id: Long, isMaster: Boolean } 我有以下方法道/回購： MemberDao.findById(id:Long):Future[Option[Member]] MemberDao.update(id:Long, member: Member):Future[Unit] MemberDao.all() : Future

0熱度

2回答

嘲笑的ExecutorService總是返回相同的嘲笑未來

我實現了一個模擬的ExecutorService，而不需要創建線程立即返回結果： public static ExecutorService createMock() throws Exception { ExecutorService executorServiceMock = EasyMock.createMock(ExecutorService.class); Futur

0熱度

1回答

從多個HTTP請求中提取並累加結果

我遇到了一個我目前無法解決的問題。我正在做多個http請求，在每個響應中，它應該有一個Array[DTAnnotation]。我想積累所有結果列表到一個（這不是問題在這裏）。我的問題是我無法返回WSResponse的結果。我嘗試什麼： import mymodel.{DTFeatures, DTResponse, DTRequest, DTAnnotations} def checkForSp

8熱度

1回答

onComplete和foreach在Scala中的未來有什麼區別？

我想知道當我們在Scala中使用Future時，onComplete和foreach之間的區別。 f onComplete (_ => doSomething(_)) 和 f foreach (_ => doSomething(_)) 執行的代碼導致上述線路相同的結果？如果我想在完成之後做一些與未來f的事情。我該怎麼辦？我應該使用isCompleted這樣的： if(f.isCompleted)

0熱度

3回答

有條件的std :: future和std :: async

我需要做條件行爲。 std::future<int> f = pointer ? std::async(&Class::method, ptr) : 0; // ... Some code x = f.get(); 所以我想分配給ptr->method()來電或0 x結果異步的結果，如果ptr是nullptr。上面的代碼是否正常？我可以做任何這樣的事情嗎（分配'int'到'std :

2熱度

1回答

變換未來[T]給未來[嘗試[T]

我想了解以下的答案How to carry on executing Future sequence despite failure?。（希望那不是向下表決值得，因爲我想了解這裏的代碼。）我不明白mapValue如何改變未來[T]給未來[嘗試[T] def mapValue[T](f: Future[T]): Future[Try[T]] = { val prom = Promise

0熱度

1回答

與Play應用中的兩個線程混雜在一起的異步功能

我正在構建一個假設構建CSV文件的服務方法。文件和結果的標題來自不同的線程。 def buildCsv(template: Template) : Future[TemporaryFile] = { val schemaFuture = dbViewSchemaRepository.findOneByTemplateId(template.id) val resultsF