blockingcollection

2熱度

1回答

多線程SqlDataReader的過期時間

下面是場景： 我想從服務器的數據表插入到服務器B. 的數據是非常巨大的，所以我會用SqlBulkCopy的做的工作。 這裏是我的想法： 製片人：讓所有頁碼 消費：從服務器A獲得頁面數，頁面數據並寫入 DataReader的服務器 問題我遇到過： 當運行時間很長時，例外情況如下： Timeout expired. The timeout period elapsed prior to complet

c# multithreading sqlbulkcopy sqldataadapter blockingcollection 2016-11-01

---

4熱度

3回答

生產者/消費者模式使用線程和EventWaitHandle

我想這是一種代碼審查，但這裏是我的生產者/消費者模式的實現。我想知道的是會有這種情況，ReceivingThread()或SendingThread()方法中的while循環可能會停止執行。請注意，從多個不同的線程調用EnqueueSend(DataSendEnqeueInfo info)，我可能無法在這裏使用任務，因爲我必須在單獨的線程中使用命令。 private Thread mReceivi

c# multithreading producer-consumer tpl-dataflow blockingcollection 2017-02-13

---

0熱度

1回答

如何正確使用BlockingCollection.GetConsumingEnumerable？

我試圖使用BlockingCollection<T>實現生產者/消費者模式，所以我寫了一個簡單的控制檯應用程序來測試它。 public class Program { public static void Main(string[] args) { var workQueue = new WorkQueue(); workQueue.StartProd

c# task-parallel-library producer-consumer blockingcollection 2017-04-09

---

2熱度

1回答

BlockingCollection <T> .TakeFromAny，對於具有不同通用類型的集合

.NET中有一個BlockingCollection<T>.TakeFromAny方法。它首先嚐試快速獲取Take，然後默認爲等待基礎句柄的「緩慢」方法。我想用它來傾聽提供「消息」的上游生產商和提供「結果」的下游生產商。 Can TakeFromAny可以使用 - 或者是有另外一種方式，不需要重新實現 - 可以監聽添加異構類型Blocking Collections的集合嗎？ 下面的代碼是不類型有

c# generics task-parallel-library blockingcollection 2016-11-19

---

0熱度

1回答

隨着時間的推移使用BlockingCollections，Tasks和OpenCV降低性能

我正在使用Xamarin for Android和OpenCV C＃綁定庫編寫一個簡單的光學測量應用程序。 爲了將圖像採集卡與處理分離，我創建了一些阻塞集合來傳遞原始數據，然後在不同線程之間處理圖像。我有一個問題，在大約30秒的時間內，GUI顯示了精美流暢的處理視頻（15s），然後是波濤洶涌的視頻（10s），然後是崩潰。 下面的代碼顯示了集合的定義。 OnCameraFrame（代碼的底部）將每個

c# android opencv blockingcollection 2017-04-18

---

-1熱度

1回答

禁止收集停止處理由於某種原因

我有阻止收集一些列表，我在任務中處理它 - 將阻塞收集的數據添加到數據庫。 下面是代碼的某些部分：從DatabaseClass private static Task _databaseTask; private static readonly BlockingCollection<List<SomeItem>> DataToBeInsertedToDatabase = new Blocking

c# task blockingcollection 2016-06-28

---

1熱度

1回答

WebClient不支持併發I/O操作 - DownloadStringAsync - 刮

首先，我已經閱讀了類似的問題，他們沒有給我一個連貫的解釋。我使用BlockingCollection<WebClient> ClientQueue來提供Web客戶端。我給他們處理功能，並啓動異步刮： // Create queue of WebClient instances BlockingCollection<WebClient> ClientQueue = new BlockingColl

c# webclient blockingcollection 2017-09-26

---

0熱度

1回答

任何方式知道什麼時候BlockingCollection中的所有任務完成執行？（任務將在開始時被刪除，但如果exec想完成，我想知道）

我正在嘗試創建單個消費者和多個生產者模式。生產者將向BlockingCollection添加任務，而消費者將運行這些任務。我想知道是否有辦法知道消費者產生的所有任務的執行是否完成。 public TaskQueue(IProducerConsumerCollection<Task> workTaskCollection) { _workTaskQueue = new Bl

c# asp.net .net task-parallel-library blockingcollection 2017-08-11

---

1熱度

1回答

等待消費者使用BlockingCollection作爲隊列的異步方法

我正在從一個服務器端控制檯應用程序接收來自多個WCF服務的數據，做了一些工作，然後通過使用SignalR的單個連接轉發結果到IIS服務器。 我試圖用生產者消費者模式實現這一點，其中WCF服務是生產者，使用SignalR發送數據的類是消費者。對於隊列我使用BlockingCollection。 但是，當使用await/async發送消費者while循環中的數據時，直到所有其他線程完成將數據添加到隊列

c# .net multithreading asynchronous blockingcollection 2016-07-15

---

2熱度

1回答

有沒有辦法簡單地返回一個BlockingCollection

你好，我想創建一個應用程序，與流數據...（所以沒有Ending..Complete ....等） 由於其本質，因爲流數據得到了很多操作，我使用BlockingCollection，它的工作原理非常棒... 我跟隨了優秀的帖子here關於SO，我擁有了所有的工作，因爲他們應該....但令我感到困惑的是，我不能簡單只是從一個類返回BlockingCollection養活輸入 事情是這樣的： clas

c# multithreading blockingcollection 2017-10-09

---