future

    0熱度

    1回答

    應用背景: 我正在使用異步項處理器並將委託作爲複合處理器傳遞。當我在處理器中遇到異常時,我的寫入錯誤偵聽器被調用。 onWriteError方法簽名(例外的例外,列表項) 問題: 名單上的所有項目,以onWriteError方法是今後的任務。如果我在將來的任務中調用「get」方法,它會給我造成寫入錯誤的異常。 如何在異步執行期間在編寫器監聽器方法中獲取原始項目? 我無法提供任何實際的代碼,因爲我的

    9熱度

    3回答

    的​​有以下方法: Future<?> submit(Runnable task) 但由於這Future的get方法將總是返回null不會以下簽名更合適? Future<Void> submit(Runnable task)

    1熱度

    2回答

    我正在使用Guava Futures將未來的調用鏈接在一起。特別是我使用的組合爲Futures.transform(...)和Futures.transformAsync(...),但生成的代碼不是非常可讀。有沒有辦法以更「流利」的方式表達同樣的東西?

    0熱度

    1回答

    這裏是我的配置:Windows 7的64位的Python 3.5.3 64位 我試圖通過安裝文件,安裝未來0.16.0.tar.gz(因爲我沒有連接到互聯網),我得到這個錯誤: * ... byte-compiling build \ bdist.win-amd64 \ egg \ libfuturize \ fixes \ fix_add__future__imports_except_unic

    1熱度

    1回答

    我讀新的C++關於改進std::future和std::promise這裏http://www.open-std.org/jtc1/sc22/wg21/docs/papers/2014/n3857.pdf建議,並說 它是一種常見的情況是,身體的一個當時的函數對象 本身就是一個基於未來的操作,它導致then() 返回future。在這種情況下,幾乎總是您真正關心的是內部未來的情況,因此 在返回之前執

    4熱度

    1回答

    在論文N3784中的std::future::then的接口包括接受執行程序的重載版本(在此更詳細地在N3562中描述)作爲參數。因此,如果您想要更多地控制執行回調的線程,則可以這樣做。 但是,併發TS中的所有功能(這裏是http://www.open-std.org/jtc1/sc22/wg21/docs/papers/2015/p0159r0.html#futures.unique_futur

    1熱度

    1回答

    兩個未來的異步操作我討厭問 - 我真的,但這個已經讓我的那一刻.. 我想創作一些動作(在播放框架 & scala)與我的主要指南是this vid。然而,它是在幾年前取得的,因此一些功能已經被棄用,因此我必須隨時找到解決方法。目前我正在嘗試在某些HTML標記中輸出兩個異步操作。 我成功地輸出一個動作與此控制器: package controllers import akka.actor.Act

    0熱度

    3回答

    我有一個類似的代碼: for (n <- 1 to 1000) { someFuture map { // some other stuff } 這是一個代碼基本部件和工作正常。但是,somefuture會對數據庫執行一些查詢,並且數據庫不能並行接收多個查詢,而這正是之前發生的情況(它會產生大量執行somefuture的線程,正如人們所期望的那樣)。理想情況下,我希望順序

    1熱度

    1回答

    我嘗試提交併在同一個流中獲得10 Future s。每個人都需要1秒的時間來處理,我想平行運行它們。 我的第一次嘗試是takes_10_sec(),它依次運行,需要10s。 我的第二次嘗試是takes_1_sec()它並行運行並需要1秒。然而它使用中間的.collect(Collectors.toList()).stream(),我認爲這不是一個好的方法。 還有另一種推薦的方法嗎? public

    1熱度

    1回答

    我有一個簡單的程序有兩個線程,其中一個將packaged_task推入deque,其他執行它。在任務中有一個this_thread::sleep_for,我期望只有「進程」線程會等待它,但是兩者都在等待,使得執行順序。我錯過了什麼? #include <future> #include <iostream> #include <deque> std::mutex m; std::cond