future

6熱度

2回答

如何在不等待的情況下使用未來？

下面的例子是從C++ async tutorial採取： #include <future> #include <iostream> #include <vector> int twice(int m) { return 2 * m; } int main() { std::vector<std::future<int>> futures; for(int i =

c++ asynchronous future 2017-06-04

---

1熱度

1回答

Netty ChannelFuture如何通知不會導致死鎖

我已閱讀Netty指南，它不會在ChannelFuture上解釋太多。我很困惑，爲什麼它不會造成僵局。 1.它教我如此啓動一臺服務器。 ServerBootstrap sb = new ServerBootstrap(); sb.group(bossGroup, workerGroup); sb.channel(NioServerSocketChannel.class);

java netty future 2017-06-06

---

1熱度

1回答

流的HTML瀏覽器未來完成

當我試圖流期貨爲的Html（在斯卡拉劇2.5.2）的想法是，它們會呈現在屏幕上時，期貨完整。所以我會流一來源作爲字符串這樣的： def oneFuture = Action { request => val source1: Source[String, NotUsed] = fromFuture(sc.makeServiceCall("async1")) Ok.chunked

scala playframework stream akka future 2017-06-07

---

0熱度

1回答

重新排隊期貨與ASYNCIO

我試圖找出如何重新排隊已超時（我使用uvloop和aiodns模塊）一些異步DNS請求異常後。 下面是我設置的循環與代碼： asyncio.set_event_loop_policy(uvloop.EventLoopPolicy()) loop = asyncio.get_event_loop() resolver = aiodns.DNSResolver(loop=loop) sem =

python asynchronous task future 2017-06-10

---

1熱度

1回答

可變數量的期貨

我必須在斯卡拉的2D列表上執行一些操作，並且我正在試圖平行該任務。 目前我有三個期貨，其中每個都需要N行矩陣並執行必要的計算。它是這樣寫的： val future1: Future[List[Int]] = Future { makeCalculations(0, 5) } val future2: Future[List[Int]] = Future { makeCalculations(6,

multithreading scala asynchronous multidimensional-array future 2017-06-11

---

0熱度

2回答

在創建的將來提交操作

我有一個Future lazy val，它獲得一些提交未來操作的對象和函數。 class C { def printLn(s: String) = println(s) } lazy val futureC: Future[C] = Future{Thread.sleep(3000); new C()} def func(s: String): Unit = { futu

scala concurrency future 2017-06-11

---

0熱度

2回答

Vert.x處理程序檢查檢查存在的最佳做法是什麼？

我正在實施一種方法，使用Vertx檢查數據庫中是否存在某個值，並使用Handler和AsyncResult。 我想知道哪一個是最好的做法： 選項1：如果沒有發現，處理程序與succeededFuture但結果爲FALSE： public void checkExistence (..., String itemToFind, Handler<AsyncResult<Boolean>> result

asynchronous reactive-programming future vert.x 2017-06-12

---

0熱度

1回答

斯卡拉期貨和多線程

我是新來斯卡拉，我試圖讓期貨的手柄和多線程 我有一個程序的版本的SingleThreaded，使得在矩陣的一些計算 SingleThreadCalc { def run(matrix : Seq[Seq[Double]]) : Future[Seq[Seq[Double]] = Future{doMath(matrix)} } 我現在想要的是製作一個多線程版本。 是否足夠讓一個Ex

multithreading scala future 2017-06-15

---

0熱度

1回答

Scala的未來[的myType]至MYTYPE

我有未來[MyType的]，我需要的MyType的值傳遞給它返回SEQ方法[未來[MyType的]，的問題，所以基本簽名是： val a: Seq[Future[MyType]] = ... getValue(t: MyType): Seq[Future[MyType]] = {...} 我想要的值傳遞給的getValue。我想是這樣的： val b:Seq[Future[MyType]]

scala future 2017-06-15

---

0熱度

1回答

我想要做一些未來的成交訂單在CompletableFuture列表

我有一些服務回報CompletableFutures這樣 Set<CompletableFuture<String>> futures = service.getSomething(); for (CompletableFuture<String> future : futures) { System.out.println(future.get()); } 該代碼打印值迭代順

java future completable-future 2017-06-16

---