concurrent-queue

    2熱度

    1回答

    我正在讀this question,並注意到OP正在迭代列表以將項目排入ConcurrentQueue。 ConcurrentQueue<TaskClass> cq = new ConcurrentQueue<TaskClass>(); for (int x = 0; x < TaskList.Count; x++) cq.Enqueue(TaskList[x]); 這是必要的嗎?

    1熱度

    2回答

    C++容器是supposed to be thread-safe by default。我必須用queue錯誤地多線程,因爲這樣的代碼: #include <thread> using std::thread; #include <iostream> using std::cout; using std::endl; #include <queue> using std::queue;

    0熱度

    1回答

    我無法弄清楚我的C#代碼出了什麼問題。 我在學習如何在System.Collections.Concurrent命名空間中使用ConcurrentQueue類。 爲了做到這一點,我在不同的線程中創建了2個相同類的實例,並向構造函數傳遞了一個不同的Listbox控件。 我期待EventGenerator的每個類實例以隨機間隔引發事件,更新隨機生成的數字傳遞的Listbox,並將該數字添加到也傳遞給構

    1熱度

    1回答

    我有一個List<TaskClass> TaskList項目,我們可以使用並行循環迭代。 由於TaskClass使用自己的CompareTo(object obj)方法實現IComparable,因此列表中的項目按特定順序排序。 因此,我們需要按順序執行的項目。 請注意,它們不必按順序完成,只需按順序開始即可。 因此TaskList [0]應該先啓動;然後TaskList [1],TaskList

    -1熱度

    1回答

    我使用併發隊列,並通過創建Action委託 Action action =() => { SubscriptionResponseModel subsModel; while (concurrentQueue.TryTake(out subsModel)) { MakeTransactionAndAddIntoQueue(sub

    0熱度

    2回答

    在下面的代碼中,我們有一個可變數組,它由兩個併發隊列進行變異。由於併發隊列不是線程安全的,因此這段代碼最好應該崩潰,但是這個代碼不會發生任何異常或崩潰。 請幫助我理解這種行爲。任何幫助將不勝感激:-) @interface ViewController() @property(nonatomic, strong) NSMutableArray *arr; @end

    -1熱度

    1回答

    在我CheckQueue()方法(通過調用AppQ.Connect(Time))和TryDequeue每個項目關閉它我想要做的就是不斷地從隊列中讀到的東西。經過一段時間(也許一分鐘左右)後,我想返回到隊列 - 再次連接,檢查它是否有一些元素(AppQ.Count),閱讀它們(通過TryDequeue()),並無限期地執行此過程。 這是一個應用程序,它將成爲一個Windows服務(目前是用於測試目的

    2熱度

    2回答

    我有一個ConcurrentQueue和一個我需要獲取源代碼的URL列表。當以ConcurrentQueue對象作爲輸入參數使用Parallel.ForEach時,Pop方法不會工作(應該返回一個字符串)。 我正在使用MaxDegreeOfParallelism並行設置爲四。我真的需要阻止併發線程的數量。是否使用並行冗餘的隊列? 在此先感謝。 // On the main class var i

    1熱度

    1回答

    我正在將一組〜300位圖保存在併發隊列中。我正在做這個over-tcp視頻流媒體節目。如果服務器速度變慢,我將接收到的位圖保存在此隊列中(緩衝)。我創建了一個單獨的項目來測試,但我遇到了一些問題。 雖然寫入線程正在工作(寫入隊列),但圖片框顯示隊列中的圖像,但它似乎跳過了其中的很多圖像(就像它正在讀取剛添加到「列表」中的圖片)通過寫入線程而不是FIFO行爲)。當寫入線程完成圖片框時,雖然我從隊列中

    0熱度

    1回答

    我有一個c#應用程序正在從一個數據庫中取數據,進行必要的轉換,並將數據插入到另一個數據庫的表中。我通過將我的源數據插入到隊列中,然後處理隊列以將數據插入到目標表中來完成此操作。我有兩個獨立的線程來讀取源數據並寫入目標數據。閱讀線程的運行速度比寫入線程快得多,所以我的隊列填滿很快。 正如您在閱讀線程中所看到的,我使用SqlCommand.ExecuteReader()來讀取數據。然後我循環遍歷隊列並