concurrency

    1熱度

    1回答

    在斯卡拉2.11.8我使用par來並行化一個大而長的foreach。我還試圖優化代碼以避免每次都創建對象的新實例,因此我需要使用DynamicVariable。但是,我注意到仍然有很多這個類創建的實例,這導致我認爲par總是跨越新線程而不是重用它們。因此,OP如何使par從線程池中消耗有限的可重用線程?這可能嗎? for (k <- 0 until 5) { // avoid creat

    0熱度

    2回答

    我在同一主機中安裝了兩個weblogic服務器版本(12.1.3和12.2.1.3)。 192.168.0.10:7001和192.168.0.10:7003。 我發現如果我登錄一臺主機並進行操作,我無法登錄或在同一臺客戶端計算機上的另一臺主機上運行。它將重定向到登錄頁面。這是正常的嗎?如果訪問Web應用程序,會影響生產後的操作嗎?

    0熱度

    2回答

    我有兩個相同長度的迭代,我需要同時循環。一個迭代是自定義對象的Map,另一個是對象的數組。我需要將數組的內容添加到Map中(通過一些輔助函數原型函數),最好是異步併發的。而且,這兩個容器根據它們的順序相互關聯。因此,數組中的第一個元素需要添加到Map中的第一個元素。 如果我是這樣做同步,將是這個樣子: var map; var arr; for (var i = 0; i < arr.leng

    2熱度

    2回答

    現在我正在構建一個分佈式應用程序,並且正在考慮使用rpc:cast vs rpc:call,因爲我不希望調用進程在返回值上等待,甚至不會收到它。 演員完美的工作,但我很好奇,什麼過程執行rpc傳遞的功能:鑄造和調用?我應該擔心是否在併發? 通常,當我想要另一個進程執行代碼時,我使用一個worker池併發送其中一個與gen_server進行異步轉換:cast/2並讓它們處理它。但對於RPC,它並沒有

    4熱度

    1回答

    實現Java中的線程安全的ArrayList我想寫它支持一個簡單的線程安全的ArrayList: 的add(),刪除(int i)以插入(int i)以,更新(INT I )和get(int i) 一個簡單的實現是向內部數據結構(例如對象數組)添加鎖,但它不夠好,因爲一次只能有一個線程訪問列表。 因此,我最初的計劃是爲每個數據槽添加鎖,以便不同的線程可以同時訪問不同索引中的元素。數據結構如下所示:

    1熱度

    2回答

    對不起我的英文不好。 有一個很大的風暴集羣,工作人員總是同時創建一些文件,問題是我不想重複這個文件名。 我的老闆讓我用格式'timestamp-random-othername'創建一個文件名,時間戳是自1970-1-1 00:00:00以來的一個數字,隨機數是從00000到99999的五位數。大約有一個數千名工作人員正在運行......並在不同的機器上運行我正在尋找一種使時間戳相同時隨機數不同的

    0熱度

    1回答

    我試圖找出一種很好的方法來使用Python 3.6中的multiprocessing包運行一組大約100個任務,其中最多同時運行4個任務。我也想要: 反覆收集池中下一個完成的任務並處理其返回值,直到所有任務都成功或失敗; 使任何給定任務中拋出的異常非致命,所以我仍然可以從其他任務中訪問結果。 我不需要維護提交給池的任務的順序(即我不需要隊列)。任務總數(「100」以上)不是非常大,例如,我不介意一

    1熱度

    2回答

    所以鎖定自由是當你有保證整個系統進展,雖然有些線程可能會餓死。所以基於CAS的實現將提供這種保證。 然後無阻塞是當一個線程保證完成,如果所有其他線程都掛起。 你能給出一個簡單的無鎖定算法的例子嗎? 謝謝!

    0熱度

    1回答

    我正在嘗試使用因子問題的fan in - fan out模式。但我越來越: fatal error: all goroutines are asleep - deadlock! ,並不能確定死鎖的原因。 我想同時使用扇入扇出模式計算100個數的階乘。 package main import ( "fmt" ) func main() { _inChannel :=

    1熱度

    1回答

    我已經在谷歌論壇發佈了這個問題,但沒有得到明確的答案。 有人可以驗證我的理解Little的法律在鎖定的情況下是否正確。假設我有一個系統讓我獲得鎖定,做一些工作並釋放它。此外,假設做一些「工作」沒有時間。 λ = L/ W (λ = throughout, L=Average number of customer in a stable system, W=Average time spent