现在，我的使用者生成了一个具有foreach (<object> in BlockingCollection.GetConsumingEnumerable())循环的线程。private void Process () { // This method runs in a separate thread foreach (*work* in BlockingCollection.GetConsumingEnumerable因此，我要重申:如何正确地在<em
浏览 5提问于2013-11-11得票数 7
回答已采纳
1回答
在windows服务应用程序中，我将多个线程启动为：{ // BlockingCollection<T>.Add() // BlockingCollection<T>.GetCons
浏览 0提问于2014-01-09得票数 2
回答已采纳
在下面的代码中，我使用CancellationToken在生产者不生产的时候唤醒GetConsumingEnumerable()，并且我想要跳出foreach并退出任务。userToken.CancelToken = new CancellationTokenSource();
foreach (var broadcast in userToken.BroadcastQueue.GetConsumingEnumerable
浏览 2提问于2012-02-02得票数 8
我有一个简单的类，它对要执行的操作进行排队： }{
foreach (Action action in this.blockingCollectionOfEvents.GetConsumingEnumerable现在，我需要取消BlockingCollection</
浏览 14提问于2022-06-03得票数 1
回答已采纳
我有一个线程，它是添加项目到一个BlockingCollection。我想清除BlockingCollection。有人能帮我一下吗？
浏览 37提问于2019-11-11得票数 0
在C# 4.0中，我使用BlockingCollection来实现生产者-消费者模式。
BlockingCollection保存的项目占用了相当多的内存。我在想，通过在BlockingCollection.GetConsumingEnumerable()上使用foreach，BlockingCollection每次都会从底层队列中删除项(这意味着所有项都与引用一起似乎BlockingCollection.GetConsumingEnumerable()
浏览 0提问于2010-10-21得票数 6
1回答
制片人称blockingCollection.Add()为foreach (var item in blockingCollection.GetConsumingEnumerable()本质上，需要一些非使用者线程在使用BlockingCollection的某一项时得到通知，。我可以在使用者中设置一个AutoResetEvent，但这只会唤醒一个等待更改的线程，而此时可能存在多个线程：
foreach (var item in blockingCollection.<em
浏览 1提问于2015-06-19得票数 0
回答已采纳
在Stephen的书第88页
private BlockingCollection<T> _streamingData = new BlockingCollection<T>();item => Process(item));var q = fromitem in _streamingD
浏览 4提问于2012-01-28得票数 4
回答已采纳
1回答
任务取消最佳实践
、、、
这是在观察要处理的文件的BlockingCollection<T>时作为Task运行的。class FileProcessor private readonly BlockingCollec
浏览 0提问于2011-11-16得票数 8
回答已采纳
1回答
多线程和信号量与事件
、、、
我正在尝试执行一些来自RabbitMQ的命令。大约5毫升/秒。因此，由于有太多的msg，我必须发送到一个线程来执行，但是我没有那么多线程，所以我设置了10的限制。经过一些实验，我不知道为什么，但我的线程只执行3或4个项目，然后它就停止了，没有错误…为什么只处理前4个味精？？下面是我代码的一些部分：private stati
浏览 1提问于2018-05-17得票数 1
回答已采纳
2回答
我将使用下面这样的BlockingCollection，只是想检查它是否适合线程安全等。我想知道我是否需要CancellationTokenSource来做任何事情。谢谢{ blockingCollection= new BlockingCollection<int>();
浏览 0提问于2012-09-26得票数 1
回答已采纳
我使用一个BlockingCollection来实现一个任务调度程序，基本上： readonly BlockingCollection<Task> m_taskQueue = new BlockingCollection<Task>();
{
m_thread = new Thread(() =>
浏览 6提问于2014-04-09得票数 11
回答已采纳
<string> blockingCollection = new BlockingCollection<string>();
{
blockingCollection.Add(string.Format("Itemprivate void Consume(BlockingColle
浏览 6提问于2015-04-23得票数 0
回答已采纳
我如何在[3]中处理这样的问题，这样消息就不会丢失，重要的是什么！消息的顺序不会混淆，因此上层服务/层将按照消息的传入顺序来获取消息。我有一个涉及另一个中间Queue的想法，但它看起来很复杂吗？不幸的是，BlockingCollection<T>没有公开任何类似于Queue.Peek()方法的内容，所以我只需要读取下一个可用的消息，如果成功的话，请执行Dequeue()。and as soon as any comes in - process it
浏览 2提问于2012-11-27得票数 11
回答已采纳
我偶然发现了一种使用BlockingCollection作为队列和前端循环来处理该队列的方法：varTask.Factory.StartNew(() => {Dim t = Task.Factory.StartNew(Sub()
浏览 4提问于2020-06-10得票数 1
回答已采纳
我决定使用Concurrent.BlockingCollection，作为测试，我做了以下程序： }
浏览 0提问于2014-02-24得票数 1
回答已采纳
6回答
我有一个向BlockingCollection添加项目的线程。在另一个线程上，我使用的是foreach (var item in myCollection.GetConsumingEnumerable())
如果有问题，我想打破我的foreach和我的方法，并清除BlockingCollection中剩下的任何东西，但是我找不到一种方法。
浏览 3提问于2011-11-04得票数 22
回答已采纳
1回答
这通常迫使我通过分组/分区数据来即兴发挥作用，换句话说，使用BlockingCollection<T[]>而不是BlockingCollection<T>。这是一个。这是可行的，但它是丑陋和容易出错。因此，我有了实现一个块状BlockingCollection的想法，它将在内部处理所有这些复杂的问题，并将与现有BlockingCollection的相同简单接口具体化。对于极细粒度的数据(基本上只是整数值)，我最好的尝试仍然支付大约+100%的性能税。因此，我想在此介绍我迄
浏览 0提问于2019-07-06得票数 0
我有几个生产者谁会不断填充到一个有限的容量为200的BlockingCollection。我正在使用反应式扩展并调用下面这样的异步方法，我想知道这是否是实现它的正确方式(使用GetConsumingEnumerable会不会有任何性能/并发问题，因为每个订阅者都会得到单独的订阅者)。根据GitHub上的其他文档，我已经使用了FromAsync as来避免在订阅者上调用异步。userActivites是一个BlockingCollection。此代码在ASP.NET Web REST API的后台线程上</
浏览 11提问于2019-12-16得票数 0
云服务器
ICP备案
云直播
对象存储
腾讯会议
腾讯云开发者
