actor-model

    0熱度

    1回答

    我目前正在使用Scala使用的日誌記錄機制,但遇到了一個意外問題,導致無法正常工作。爲了測試功能,我正在設置一個簡單的消息傳遞環。在環內,每個節點都是Scala Actor的擴展,並且知道它是直接的鄰居(上一個/下一個)。 該環結構是如下進行,用參數「節點」從控制器演員被傳遞: def buildRing(nodes:Array[Actor]){ var spliceArr:Array[

    2熱度

    1回答

    我想了解給定服務結構集羣中任何時候將執行給定方法(在給定actor角色上)的actor id實例的最大數量。這是我的例子: 比方說,我只是定義一個演員類稱爲CustomerActor從服務織物的演員派生並實現其具有稱爲Process一個方法ICustomerActor接口。 假設我有一個客戶端,它通過使用基於客戶ID的actorIds將消息發送到ICustomerActor.Process方法。在

    1熱度

    1回答

    有什麼乾淨的方式讓WCF調用根據請求參數應用1的最大並行度? 假設下面的代碼: public void MyWcfOperation(int entityId, other arguments) { //do stuff with entity with id = entityId } 我要處理的最大的基於ENTITYID這裏1個parallell電話。 我知道我可以爲WCF設

    3熱度

    3回答

    我是斯卡拉和演員世界的新人。 這是我到目前爲止已經瞭解到: Scala是函數式編程(不是純粹的),人們建議不要在使用階可變狀態。 但另一方面,有一個AKK框架實現演員模型。在玩阿卡時,我意識到信息是不變的,但是MUTABLE中的角色的狀態。所以,我需要在actor的「var」變量和可變集合中指定。而且,對我來說,有一個可變狀態並不適合scala。 那麼,我的理解是否正確? 爲什麼人們採用不可變的斯

    3熱度

    1回答

    我尋找JoinBlock的替代品,可以通過n-TransformBlocks鏈接到JoinBlock,並將所有TransformBlock源塊的消息連接/合併在一起,以便將這樣的集合傳遞給另一個數據流塊。 JoinBlock可以很好地工作,但它僅限於連接3個源塊。它也有許多低效率(加入2個源塊的偶數值類型(整數)非常慢)。是否有辦法讓TransformBlocks返回任務,並等待所有Transfo

    0熱度

    1回答

    在我的J2EE Web應用程序中,我必須爲每個Web API調用發送一個計數給一個隔離線程以統計調用次數。可能性包括: a)使用原子長。我認爲這會在一分鐘內有數百萬電話的情況下引起爭議。因爲所有線程都會嘗試更新單個變量。 b)使用共享隊列。每個請求處理線程都會插入到隊列中,專用計數器線程將從該隊列中退出並增加計數。 c)使用actor模型,比如使用Akka庫。向演員發送異步消息,然後將其添加到計數

    0熱度

    2回答

    我是scala的新手,我正在寫scala代碼來實現糕點協議。協議本身並不重要。有節點,每個節點都有一個我想要填充的路由表。 下面是部分代碼: def act() { def getMatchingNode (initialMatch :String) : Int = { val len = initialMatch.length for (i <- 0 to noOfNodes-1)

    12熱度

    1回答

    在1978 Paper by Hoare we have an idea called Communicating Sequential Processes。這由Go,Occam和Clojure在core.async中使用。 是否可以使用CSP作爲替代Scala中角色模型?(我看到JCSP,但我想知道這是否是唯一的選擇,如果它是成熟的,以及是否有人使用它)。 編輯 - 我也看到Communicat

    8熱度

    2回答

    https://en.wikipedia.org/wiki/Actor_model,該項目被稱爲「pulsar」 https://en.wikipedia.org/wiki/Reactor_pattern,項目被扭曲和龍捲風 是什麼在理論和實踐上的區別?

    3熱度

    1回答

    我一直在研究演員模型一段時間,並試圖找出如何將其與RESTful API正確結合。我正在努力如何分離兩個層的責任,無論是通過使用ask-pattern還是actor-per-request。對於這兩種模式,請求 - 回覆語義都泄漏到actor模型中,這看起來像是一種反模式。大多數由HTTP請求發起的消息發送給演員需要回復。接收參與者有多個條件,它需要指示API無法完成請求。 此外,什麼被認爲是輸入