concurrent-programming

    1熱度

    1回答

    我正在開展一項學術研究,嘗試開發一種編程工具來協助實現細粒度的鎖定函數,用於維護樹狀數據結構的併發程序。例如,程序員可以編寫一些接收樹根節點並修改樹(通過遍歷某些路由並添加/刪除節點)的函數,該工具將幫助他找到代碼節點中的哪個部分應該被鎖定以及它們可以被釋放的位置 - 因此這些功能可以在同一棵樹上同時執行。 我正在尋找一些真實的代碼示例,其中使用了這種細粒度的鎖定,或者它可以用於獲得更好的性能,但

    1熱度

    1回答

    可能重複: Start/Suspend/Resume/Suspend … a method invoked by other class 我想實現的任何時候K-NN分類,但我無法找到一個方法來調用「將方法分類(...)「一段特定時間,暫停它,在方法被暫停之前獲得可用結果,恢復方法一段特定時間,暫停它,在方法被暫停之前獲得可用結果,等等...... 提前致謝!

    1熱度

    1回答

    我想實現一個Anytime k-NN分類器,但我找不到一種方法來調用特定的「classify(...)」方法時間量,暫停它,在方法被暫停之前獲得可用的結果,恢復方法一段特定的時間,暫停它,在暫停方法之前獲得可用的結果,等等...... 我使用數據結構獲取近似結果。當算法遍歷數據結構時,最終會遇到實際的訓練數據向量。 public class AnytimeKNN{ public int clas

    -1熱度

    1回答

    考慮Ada95的下列控制器(受保護對象),以適應一個任務調用Waiting()這一次它不會對即將投入如果等待標記(標記)已經相當於上選擇(Selecting_Marker)的標記僅自然它的前初始化: protected type Controller is entry Waiting(Marker : in Marker_Type); procedure WakeUp(Mark

    2熱度

    4回答

    經過一番研究,我正在尋求任何有關如何有效地從Concurrent集合中刪除兩個項目的反饋。我的情況涉及通過UDP傳入的消息,這些消息當前正在放入BlockingCollection中。一旦集合中有兩個用戶,我需要安全地接收兩個用戶並處理它們。我見過幾種不同的技術,包括下面列出的一些想法。我目前的實施情況如下,但我認爲有一個更清晰的方法可以做到這一點,同時確保用戶按兩組進行處理。這是這種情況下唯一的

    2熱度

    1回答

    我想掌握併發編程。 我聽說有好書併發編程在java中由Doug Lea的 Concurrent Programming in Java™: Design Principles and Pattern (2nd Edition) Java Concurrency in Practice 哪本書應該我第一次看?還有其他書嗎?如果有人能告訴我也指導我如何練習這個話題。

    1熱度

    1回答

    除了隱式用戶界面線程,我做了兩個線程(可運行),兩者都具有在其內部while循環中,我定期檢查,我已經實現了一個消息隊列中更新。 首先問題在於兩個while循環是無限的,它們變化如此之快以致於它們幾乎耗盡了設備的所有CPU。 所以我想關於做while循環睡覺大約100毫秒爲單位每個週期後,讓其他線程做他們的工作,但我遇到了另一個問題: 現在的問題是,線程睡眠100毫秒,但他們不會讓UI線程在這段時

    1熱度

    2回答

    使用Parallel Extensions時是否需要關注MemoryBarriers? 編輯 - 擬定爲原來的問題是開放式的: (@xanatos的回答是一個我一直在尋找) 舉一個具體的例子:假設我使用Parallel.ForEach和每次迭代設置類中屬性的值(每次迭代設置它自己的特定屬性,沒有兩次迭代設置相同屬性的值)。在調用Parallel.ForEach的同一個線程上,我訪問從Paralle

    1熱度

    1回答

    如果我使用ConcurentDictionary DIC在多線程訪問的方法,我可以肯定的是,在這樣的結構: foreach (Subscription sub in subscriptions[ex].Values) { .... } subscriptions運行時ConcurrentDictionary<string, Concurr

    1熱度

    4回答

    我想調用一個java中由於某種原因阻塞的方法。我想等待X分鐘的方法,然後我想停止該方法。 我在StackOverflow上讀到了一個解決方案,它給了我一個第一個快速入門。我寫在這裏: - ExecutorService executor = Executors.newCachedThreadPool(); Callable<Object> task = new Callable<Obje