reactor

    2熱度

    1回答

    執行暫停使用Linux timerfd的想知道使用timerfd(timerfd_create)的爲Linux是否會給予超過Timer_Heap或Timer_Wheel任何性能優勢。 當然,這是一個非常高的水平的問題,我所看到的唯一的地方,它在任何框架正在使用的「muduo」。還有,我沒有任何的性能比較,以及。 謝謝。

    2熱度

    1回答

    我們正在評估在我們的項目中使用它的反應堆庫。我們的項目得到了春天的支持。所以我們需要一個工具來構建具有彈簧支持的事件驅動應用程序。 此外,我們主要關注的領域是組合異步事件序列(流& Promises)的能力。在某些其他用例中,我們可能需要發佈者/訂閱者模型或異步運行長時間運行的進程。 正如我正在評估的那樣,我注意到以下一些最新發布的reactor-spring版本是v1.1.3,依賴於我們可以使用

    0熱度

    1回答

    我有一個RTSP流,我需要重新流爲HLS。當RTSP數據流出現故障時(例如,攝像機斷開),我放置一個藍屏,讓用戶知道攝像機已脫機。 HLS分段器單獨運行,在端口22200上偵聽傳入數據包。 在Python代碼本質歸結爲: import psutil, subprocess as sb from twisted.internet import reactor, task from cameraC

    0熱度

    1回答

    標題很好解釋它; 可能嗎?我想創建主備關係,如果主服務器出現故障,備份接管,成爲主服務器並創建自己的備份並繼續運行。目前我正在使用listenMulticast進行廣播。 我想要一個行爲,在終端打印越來越多的數字用於學習目的。如果我發送某種中斷信號,主人應該被銷燬,但是從上面開始,關係被重新創建並且數字不斷被打印。爲此,我不在乎數字是否被跳過,我只是在結構之後。 謝謝。

    0熱度

    1回答

    有人可以展示如何通過Reactor框架執行map/reduce操作的代碼示例嗎?我想說我有Collection<Map>。我想: 變換每個Map實例Foo型併發的對象(每個實例是完全獨立的另一個 - 也沒有必要給每個串行/反覆轉換)。 當它們全部被轉換時,我想調用一個方法onReduce(Collection<Foo> foos) - 該參數包含所有生成的Foo實例。

    1熱度

    1回答

    修修補補的幾個小時之後和嘗試片斷蟒蛇結果定期運行Scrapy,我在計算器中,我終於設法定期運行scrapy: timeout = 60.0 # seconds class UrlCrawlerScript(Process): def __init__(self, spider): Process.__init__(self) settings = get_pr

    0熱度

    2回答

    下面給出的是服務器的代碼: from twisted.internet import protocol from twisted.internet import reactor class Echo(protocol.Protocol): def dataRecvd(self, data): self.transport.write(data) class Ech

    4熱度

    1回答

    我試圖在Python中實現Reactor pattern。我想我有一個非常體面的開始使用multiprocessing和select.select。但是,我試圖對我的服務器進行壓力測試,所以我編寫了一個簡單的DoS客戶端,用連接對其進行洪泛。但是,我得到一個有趣的錯誤: [WinError 10061] No connection could be made because the target

    0熱度

    1回答

    我是一個新手春天,我想在一個簡單的Spring MVC項目集成了反應器: @Controller public class HomeController { private static final Logger logger = LoggerFactory.getLogger(HomeController.class); @Autowired Reactor r

    0熱度

    1回答

    與reactor-core 1.1.4-RELEASE我在下面嘗試,但沒有打印出來。我應該錯過什麼? Reactor reactor = Reactors.reactor(new Environment()); reactor.on( $("hello"), (Event<String> ev) -> System.out.println("hello "