future

    2熱度

    2回答

    假設每個物體(汽車,自行車等)都連接到互聯網,並給我(雲)當前位置和隨機ID,每「T」秒改變一次。由於物體會改變其身份,因此很難跟蹤每一個物體,特別是在像市中心這樣的繁忙區域。有人可以幫助我設計一個攻擊者模型,它可以預測對象的軌跡。這意味着Cloud必須預測下一個對象的方向,比如15分鐘。 你可以假設像4個區域A,B,C,D(每個半徑5-10km),它們彼此接近。我怎麼能預測並說出如此多的數量的汽

    0熱度

    1回答

    我真的被龍捲風框架工作和'未來'物體所困惑。 所以,我想通過進行HTTP調用 代碼來獲得一個異步響應: class TestAsyncHttp(object): def __init__(self): self._http_client = httpclient.AsyncHTTPClient() @gen.coroutine def get_respo

    2熱度

    1回答

    我目前正在努力與scala未來回調的邏輯。 我試圖讓這應該做的方法如下: 與x值完成對如果x與失敗的異常成功完成 完成與值y如​​果x失敗,終於 完成對y如果x和y失敗。 這裏是我的代碼,因爲某些原因無法正常工作: def eitherF(x: Future[Int], y: Future[Int]): Future[Int] = { var ret : Future[Int] = x

    0熱度

    1回答

    我是相當新的使用協程編程,我試圖建立一個使用Python 2.7.10的Tornado web服務器的自定義數據庫的數據庫接口。但是,我不斷收到BadYieldError。我覺得這可能是我不瞭解如何在Python的yield中完全使用tornado.gen.coroutine。我認爲我如何產生未來可能會出現問題。 這是我的代碼保持失敗,其中第15行的testGet函數是對外部數據庫訪問的模擬。 f

    1熱度

    1回答

    對於我的fork-join-pool(默認全局)能夠分配新線程,如果我嵌套了Futures,是否需要用阻塞{...}封裝所有單個期貨,如果它們是DB調用或其他I/O /網絡進程,例如? 這是正確的嗎? Future.sequence( blocking{ val f1 = Future(...) val f2 = Future(...) val f3 =

    1熱度

    2回答

    我的代碼: val f1 = Future[String] { "ok1" } val fRes: Future[String] = for { r <- f1 } yield r 我希望fRes是一個字符串,但我得到一個Future[String]。爲什麼?我不想使用Await.result。

    2熱度

    1回答

    所以我有一些端點服務器代碼,在那裏我想異步運行的東西。爲此我使用期貨。有跡象表明,導致結果的任務,但也有不昂貴的IO任務,所以我在火災執行它們,忘記未來,像這樣:那 import scala.concurrent.Future val ec = scala.concurrent.ExecutionContext.global Future { Thread.sleep(10000

    0熱度

    2回答

    我讀了關於Scala Futures and Promises。 我知道我可以使用回調,flatMap組合或理解連鎖期貨。當未來完成時,另一個未來就開始了,等等。 有沒有辦法鏈接任意數量的期貨的執行,存儲在斯卡拉集合(例如List)? 我試圖在期貨清單上調用Future.sequence,但它們一起開始並且它們同時執行(而不是順序執行)。

    1熱度

    2回答

    我將scala.concurrent.ExecutionContext.Implicits.global用於Future的所有執行者。但有時候,我做了一件簡單的事情,只是希望它不會改變線程(不把它放到線程池中),讓它在當前線程下繼續運行。使用twitter Future其中有一個Future.value來實現此目的。如何在Scala的未來做什麼?

    0熱度

    1回答

    我有一個像這樣的文件中的驅動程序/主類。 (基本上我試圖混合STORM & AKKA)。在TenderEventSpout2類中,我試圖向演員發送消息和從演員接收消息。 public class TenderEventSpout2 extends BaseRichSpout { ActorSystemHandle actorSystemHandle; ActorSystem