使用blockingcollection和tasks .net 4 TPL的经典生产者消费者模式
经典的生产者消费者模式是一种常见的并发编程模式，用于解决生产者和消费者之间的数据交互问题。在.NET 4中，可以使用BlockingCollection和Tasks库中的TPL（Task Parallel Library）来实现这种模式。
BlockingCollection是一个线程安全的集合类，它提供了一个阻塞队列，用于在生产者和消费者之间传递数据。它可以自动处理线程同步和阻塞等待的细节，使得编写生产者消费者模式变得更加简单。
Tasks库是.NET中用于并行编程的一组工具，它提供了一种方便的方式来创建和管理多个并发任务。通过使用Tasks库中的Task类，可以将生产者和消费者的逻辑封装为独立的任务，并通过BlockingCollection来进行数据交换。
在经典的生产者消费者模式中，生产者负责生成数据，并将其添加到BlockingCollection中。消费者则从BlockingCollection中获取数据，并进行相应的处理。当BlockingCollection为空时，消费者将阻塞等待，直到有新的数据可用。当BlockingCollection达到最大容量时，生产者将阻塞等待，直到有空间可用。
这种模式的优势在于可以有效地解耦生产者和消费者，使它们能够以不同的速度工作，从而提高系统的吞吐量和响应性能。同时，使用BlockingCollection和Tasks库可以简化并发编程的复杂性，减少了手动处理线程同步和阻塞等待的工作量。
生产者消费者模式在许多场景下都有广泛的应用，例如消息队列、线程池、并发任务处理等。它可以用于解决生产者和消费者之间的异步通信问题，提高系统的并发性能和可伸缩性。
对于使用.NET 4的开发者，可以使用腾讯云的云服务器CVM来部署和运行基于.NET的应用程序。腾讯云的CVM提供了高性能的计算资源和稳定可靠的网络环境，适用于各种规模的应用部署和运行。
腾讯云产品推荐：
- 云服务器CVM：https://cloud.tencent.com/product/cvm
- 弹性容器实例TKE：https://cloud.tencent.com/product/tke
- 云函数SCF：https://cloud.tencent.com/product/scf
请注意，以上推荐的腾讯云产品仅供参考，具体选择应根据实际需求和项目要求进行评估和决策。
相关·内容
用于在System.Collection.Concurrent和一些同步类下添加新的并发功能的.NET。对于使用这些特性的单一生产者-单一消费者模式，有没有什么好的例子？(实际上，如果它还没有将其实现为共享缓冲区，我将添加一个循环缓冲区模式)
浏览 0提问于2010-10-26得票数 3
回答已采纳
2回答
我刚刚开始在.NET 4.5中编写和使用第三方公共语言，不知道您是否可以帮助我。
基本上，我的WPF程序对一组数据库记录执行繁重的工作，这些记录的范围可能在500万到1000万之间。我想利用TPL库来有效地管理这项工作，同时保持UI的响应性。
我的场景如下，我计划使用3个单独的任务来检索数据，每个任务有300万个数据，并将它们提供给我的"worker“。
我想要一个单独的任务，从上述任务中的所有项目中获取每个项目，并与它一起做一些工作。
所以我想要一个全局的项目列表，所有3个任务都可以放入项目，我的第四个任务，然后应该从这个主列表中一次挑选一个项目并对其做一些工作，如果列表是空的，它应
浏览 1提问于2014-11-18得票数 1
1回答
我有一个应用程序，在每个新的帧上做一些图像处理，最近我买了一个新的网络摄像头，与我的旧摄像头(360x240)相比，1280x960的分辨率真的很好，我的应用程序对网络摄像头中的每个新帧进行一些图像处理，但由于分辨率太高，处理速度变慢，我的应用程序挂起。我在想，我可以在应用程序启动时启动10个线程，并将每个帧从主线程裁剪成10个相等的部分，然后将其传递给工作线程，这样每个工作线程只需处理帧的一小部分。
我的应用程序分析像素颜色，并在找到正确的颜色时报告，所以我想用线程重新创建它。
我以前使用过线程和线程池，但我不太确定如何让线程保持活动状态，并在主线程运行时传递对象，所以任何一段代码都是有帮助
浏览 6提问于2012-01-04得票数 0
回答已采纳
请看下面的伪代码
//Single or multiple Producers produce using below method
void Produce(object itemToQueue)
{
concurrentQueue.enqueue(itemToQueue);
consumerSignal.set;
}
//somewhere else we have started a consumer like this
//we have only one consumer
void StartConsu
浏览 20提问于2011-06-29得票数 20
回答已采纳
几天前，我试图在我的磁盘上执行快速搜索，做一些事情，比如属性、扩展名、执行文件内部的更改等等。
它的想法是使它的限制/锁定非常少，以避免大文件或目录中有大量文件等的“延迟”。我知道这对“最佳实践”来说太远了，因为我没有使用"MaxDegreeOfParallelism“之类的东西，也没有用"while(true)”作为拉循环。
尽管如此，由于我们有支持它的体系结构，所以代码运行得相当快。
如果有人想要检查正在发生的事情，我尝试将代码转到虚拟控制台项目。
class Program
{
static ConcurrentQueue<String> dirToC
浏览 3提问于2012-10-16得票数 2
1回答
我需要实现一个生产者-消费者模式，以阅读，处理和节省电的价值。我必须在C# .NET 4.6.1中实现这一点。
我试着详细描述这一点，希望不会对我想达到的目标产生误解。我知道怎么做，但这可能不是最好的方法。
我想知道你对我的想法有什么看法，你建议如何解决这个问题。
情况
这些值由另一个程序从几个数据记录器中收集。这些值存储在每个数据记录器的文件中。我正在编写的软件有一个配置文件，它指定输入文件的目录、输出结果的位置、输入的格式、输出的格式等等。重要的是，对于每个数据记录器，都有一个关于如何处理每个(电)值的定义。
文件的数量、大小和数据记录器的数量可能会有很大差异。我假设大约有1200个数据
浏览 0提问于2016-03-24得票数 5
我很难理解BlockingCollection。下面的代码来自一个，但它使用了两个队列。
using System;
using System.Collections.Concurrent;
using System.Threading;
using System.Threading.Tasks;
namespace Demo
{
class Program
{
static void Main(string[] args)
{
new Program().run();
}
void r
浏览 7提问于2014-08-06得票数 0
回答已采纳
1回答
我需要一个集合/包(一些东西)，它将容纳一些最大数量的运行Task对象。向集合中添加一个新的正在运行的Task应该会阻塞调用线程(有许多线程试图添加任务，因此它应该是线程安全的)，直到达到最大运行任务数时，新的Task有一个可用的插槽来添加。到目前为止，这就是我所拥有的，而且效果很好。
你能发现这段代码有什么问题吗？还是有一些内置的类可以处理这类任务？
public class ConcurrentTaskLimiter
{
public int MaxWorkingTasks { get; }
private readonly Task[] _tasks;
priva
浏览 0提问于2016-12-25得票数 5
1回答
我有一个简单的程序，在一个可作为反馈枚举器实现的无穷无尽的枚举上迭代。我已经在TPL和PLINQ中实现了这一点。这两个例子都是在可预测的迭代次数之后锁定的: PLINQ 8次，TPL 3次。它不使用TPL/PLINQ执行代码，运行良好。我已经以非线程安全的方式以及线程安全的方式实现了枚举器。如果并行度限制在1(如示例中的情况)，则可以使用前者。非线程安全枚举器非常简单，不依赖于任何“花哨”的.NET库类。如果我增加并行度，在死锁增加之前执行的迭代次数增加，例如对于PLINQ，迭代次数是8*并行度。
下面是迭代器：
枚举器(非线程安全)
public class SimpleEnumerable
浏览 1提问于2016-11-29得票数 2
2回答
我不确定以下操作是否可行，但我希望以有节流的方式并行调用一些操作，但要保持处理流程的连续性，而不是返回到使用计时器或循环/睡眠周期。
到目前为止，我已经让它工作了，它从某些来源加载了大量的输入……然后以受控的方式并行处理它们&像下面这样循环。
static void Main(string[] args)
{
while(true) //Simulate a Timer Elapsing...
{
IEnumerable<int> inputs = new List<int>() {1, 2, 3, 4, 5, 6, 7, 8,
浏览 0提问于2012-02-11得票数 5
回答已采纳
3回答
我正在与C# (BMP 4.0)一起工作，以从高速摄像机捕获300个视频帧序列，这些视频帧需要保存到磁盘(.NET格式)。视频帧需要以几乎精确的时间间隔进行捕获，因此我无法在捕获帧时将其保存到磁盘--磁盘I/O是不可预测的，它会抛出帧之间的时间间隔。捕获卡有大约60个可用的帧缓冲器。
我不确定实现这个问题的解决方案的最佳方法是什么。我最初的想法是创建一个"BufferToDisk“线程，当帧缓冲区中的图像可用时将其保存。在这种情况下，主线程捕获帧缓冲区，然后向线程发出信号，指示可以保存帧。问题是捕获帧的速度快于线程保存文件的速度，因此需要某种类型的同步来处理这一问题。我在想，信号量对于
浏览 0提问于2010-12-02得票数 0
回答已采纳
1回答
我的项目需要从多个来源收集数据，然后在完成数据收集之后再做一些事情。一些收集任务依赖于以前的收集任务。TPL一直是一个很好的选择，因为它很自然地会继续执行来自其前身的任务，并且使用结果的“最终”任务也是依赖的。太棒了。然而，我们希望有一个“睡眠和恢复”任务，从完成“最终”任务开始；这个任务的任务在逻辑上是“最终”任务的先导，并开始下一个周期。实际上，TPL的DAG变成循环，或者，如果按顺序考虑，则变成一个循环。
是否可以在TPL中完全表达这种循环需求？如果是这样的话，是怎么做的？相反，我们的当前实现在前面元素上执行一个WaitAll()，然后给出一个执行睡眠的委托，然后用WaitAll()重新
浏览 2提问于2011-02-12得票数 0
回答已采纳
我正在对BlockingCollection进行一些分析，以便在UDP数据处理场景中使用它。目前，它正以单一的使用者方式使用，传入的UDP数据被写入到集合中，然后相应地进行处理。
我想我应该对多个消费者/任务进行一些分析，以提高性能，但我看到了一些奇怪的结果，所以我肯定遗漏了一些东西。
取消令牌不用于分析。
其本质是排队1000000个数字，然后从不同的线程中取出它们，我认为这会提高性能，但它会产生相反的影响。
下面是测试/分析的基本设置(控制台应用程序)
static BlockingCollection<int> Queue = new BlockingCollecti
浏览 2提问于2020-05-27得票数 0
回答已采纳
1回答
要设计的应用程序充当两个不同系统之间的桥梁。
一个人本机讲TCP (实际上是RS232，但通讯线路上有一个COM->ETH服务器)，另一个是ERP系统(能够通过web服务进行交谈)。
所以在一张照片里，它看起来是这样的：
现在，作为一名web开发人员，我从来没有与线程有太多的关系(虽然与MVC和任务有了一些变化，但还是.)。
现在，我面临着一个正确的“服务器”设计的挑战。
我已经意识到，while(true)中有一个Sleep可能不是最明智的选择。去过那里，做过那件事。
从我目前所读到的，我需要一些能阻挡我的东西。与Console.ReadKey()一样，我不希望将其作为控制台应用程序
浏览 0提问于2015-04-24得票数 1
我有一个简单的程序，返回素数之和低于某个数。
当我在不使用TPL的情况下运行该程序时，它会给出正确的结果，但是当我使用TPL运行程序时，它会给出不正确的结果。
我不明白这有什么问题。有人能帮忙吗？
以下是代码：
static void Main(string[] args)
{
var executionStartTime = DateTime.Now;
Console.WriteLine(GetSumOfPrimesBelowviaTPL(2000000));
Console.WriteLine("End Time: " + (DateTime.Now
浏览 2提问于2013-09-02得票数 0
回答已采纳
1回答
使用TPL的PC队列？
、、、、
原创
如何利用TPL和/或并发集合在C#中创建生产者-消费者队列？我用的是.NET 4.5+。
这是我的第一次尝试：
public class SampleFileProcessor
{
private readonly BlockingCollection<string> _queue =
new BlockingCollection<string>();
public void ProcessFile(string fileName)
{
// Imagine this method is inside a
浏览 3提问于2014-09-04得票数 0
1回答
同步线程通信？
、、、、
正因为如此，我正试图模拟JRuby生成器如何使用C#中的线程工作。
而且，我完全意识到C#已经建立了对收益率回报的支持，我只是在兜圈子。
我猜这是一种可怜的人的合作，通过使用线程保持多个调用堆栈的活力。(尽管不应该同时执行任何一个调用堆栈)
想法是这样的：
使用者线程请求一个值。
工作线程提供一个值并返回给使用者线程。
重复直到完成工作线程
那么，做以下事情的正确方法是什么呢？
//example
class Program
{
static void Main(string[] args)
{
ThreadedEnumerator<s
浏览 2提问于2010-04-22得票数 1
1回答
关于C#线程化的问题
、、、
我的问题是反馈，以确保我采取了正确的方法，并正确处理线程。我有一种感觉，我可能需要设置我自己的一些线程，所以所有的反馈都是欢迎的。
我的问题是从零或多个RFID阅读器读取RFID标签。我可以在没有问题的情况下为一位读者阅读，所以从几个方面的阅读不会是一个问题。读取器读取的每个标记或批次标记都通过一个.Net事件传递。
我的计划是设置一个ReaderControl类，它维护读取器、连接、启动、停止等。这个类将从读取器中侦听TagRead事件。在它处理的每个事件上(大约每250 is处理一次)，它将读取标记it (字符串)放入HashSet中以保持它们的唯一性，HashSet位于ReaderCon
浏览 4提问于2011-02-04得票数 2
回答已采纳
1回答
我有一堆产生对象(例如字符串)的线程和一个使用批量对象的线程(例如序列化它们并将它们发送到远程服务器)。
我希望生产者能够尽可能快地获取数据。它们永远不应该因为其他生产者而锁定，即使是消费者也不应该。这个是可能的吗？多么?
浏览 0提问于2014-12-31得票数 0
1回答
基于TPL的协同多任务处理
、、、、
我们正在移植建模应用程序，它在建模过程中使用IronPython脚本进行自定义操作。现有应用程序在单独的线程中执行每个Python脚本，并为此使用协作模型。现在我们想把它移植到TPL，但是首先我们想要测量上下文切换。基本上，我们现在拥有的是：
Task队列
此队列中的每个Task执行一个IronPython脚本。
在IronPython脚本中，我们调用C#类方法，它是同步点，应该将Task (IronPython执行)转移到等待状态。
我们想做的是：
我们想要做无限循环，它将遍历Task的队列。
当我们得到一个Task时，我们尝试执行它
在PythonScrip
浏览 1提问于2010-10-13得票数 7
回答已采纳
4回答
是否可以为每个循环并行处理队列中的项，以便：
在将新项添加到队列( processedPauses )之前，只移除正在执行的项。
编辑:这是关于System.Threading.Tasks的Parallel.ForEach功能
浏览 4提问于2011-07-01得票数 5
回答已采纳
ConcurrentQueue和.Net中的BlockingCollection有什么不同？
既然可以通过ConcurrentQueue完成，为什么BlockingCollection最适合生产者-消费者操作？我需要在下面的代码中改进什么吗？
MessageSlotMachineGameStartOrAndStatusUpdate msg;
while (!aCancellationToken.IsCancellationRequested)
{
try
{
this.isStillConsumingMsg = true;
Boolean ta
浏览 0提问于2012-04-04得票数 62
回答已采纳
我已经创建了一个包含BlockingCollection的简单类。它表示将按照接收到的顺序执行的操作队列。我读过很多关于TPL的文章，似乎我应该使用TPL，而不是目前使用的。原因之一是单元测试会更容易，同时也会编写更少的代码。我知道您可以很容易地使用Task.Factory.StartNew()之类的方法创建新任务，但我不确定如何以与我目前所拥有的类类似的方式使用它。我如何在TPL中完成同样的任务？
根据请求，下面是我创建的类：
public class MyService
{
/// <summary>Queue of actions to be consumed on
浏览 5提问于2016-02-22得票数 0
回答已采纳
我正在使用Func<>或Action<>.BeginInvoke通过ThreadPool异步运行方法。
有没有可能让AsyncCallback调用产生新线程的原始线程上的函数(从技术上讲，是事件)？
我知道在WinForms应用程序中，您可以使用work / ISynchronizeInvoke / Dispatcher在异步操作完成时向UI线程发出警报--但这不是WinForms应用程序，它似乎无法工作。
class SyncTest : System.ComponentModel.ISynchronizeInvoke
{
public
浏览 0提问于2012-01-18得票数 1
回答已采纳
我在视图模型中有一个绑定到块集合的列表
<ListBox Grid.Row="1" ItemsSource="{Binding PlantControllers}"
和属性
public BlockingCollection<PLANTCONTROLLER> PlantControllers
{
get { return _plant.PlantControllers; }
}
使阻塞集合可见的最简单的方法是什么，似乎找不到任何好的例子
浏览 0提问于2013-07-03得票数 3
1回答
带超时的.NET并发收集？
、、、、
我有一个并发的集合。
var q = new ConcurrentQueue<int>(); // Or a stack/bag/etc...
我可以买到这样的东西。
int i;
if (q.TryDequeue(out i))
DoStuff(i);
但我需要的是“在返回false之前等待10秒，以防有人添加新项目”：
int i;
if (q.TryDequeue(TimeSpan.FromSeconds(10), out i))
DoStuff(i);
我可以像这样写一个扩展方法：
public static bool TryDequeue<T>
浏览 0提问于2013-04-10得票数 9
回答已采纳
1回答
优化Web爬行
、、、
我正在开发一个快速的工具，可以从网页上抓取图像。目前，我使用WebClient获取页面的源数据，解析源中的图像URL，然后使用WebClient.DownloadFile将它们单独下载到一个文件夹中。这可能需要相当长的一段时间。
我知道所需的大部分时间是由于我的连接和下载数据。
有没有其他更有效的方法来做这件事，无论是C#超文本标记语言解析库还是其他什么？
浏览 0提问于2012-12-18得票数 0
回答已采纳
我有一些解析CSV的代码，它的目的是触发任务并批量处理记录。我有某种类型的并发问题，我得到一个空字符串传递到SplitCsvLineToCells。疯狂的是，当我在visual studio中向上迁移调用堆栈时，我可以看到传入的数组索引/字符串，而且它不是空的！有没有可能我遇到了垃圾回收并丢失了字符串引用？我在这一点上有点空白。传入的字符串都不应该为null (根据输入，字符串肯定是全部填充的)。代码如下：
static SemaphoreSlim semaphore;
static MemoryStream outputStream;
static StreamWri
浏览 0提问于2016-06-29得票数 1
在我的应用程序中，我有三个类，Extractor、Transformer和Loader，它们由第四个类Coordinator协调。Extractor、Transformer和Loader非常简单，并执行以下操作：
Extractor
公开名为Results的IEnumerable<string>类型的成员，例如从文本文件中读取。提取应该是同步的。
Transformer
公开一个名为Transform的成员，该成员接受一个字符串，并通过预期耗时的进程将其转换为另一个字符串(这里使用并行处理)。
Loader
公开一个名为Load的成员，该成员接受字符串并将其加载到某种最终形式(例如
浏览 3提问于2012-10-03得票数 4
回答已采纳
我试图用多个生产者和一个使用者实现并发生产者/消费者队列:生产者向Queue添加一些数据，使用者从队列中删除这些数据以更新集合。必须定期将此集合备份到新文件。为此，我创建了一个可序列化的自定义集合:可以使用DataContractSerializer执行序列化。
队列只在使用者和生产者之间共享，因此必须管理对此队列的访问，以避免竞争条件。
自定义集合在使用者和备份线程之间共享。
备份线程可以使用对象周期性地激活:它最初可能由使用者进行调度，然后在每个备份过程结束时进行调度。
最后，关闭方法应该停止生产者的排队，然后停止使用者，执行最后的备份并释放计时器。
一次一项的脱队
浏览 2提问于2012-09-13得票数 0
我试图在BlockingCollection 4上的新并行堆栈的上下文中理解.NET的用途。
文档说：
BlockingCollection用作IProducerConsumerCollection实例的包装器，允许从集合中删除尝试阻塞，直到数据可用为止。类似地，可以创建一个BlockingCollection来强制执行IProducerConsumerCollection中允许的数据元素数量的上限；然后，对集合的添加尝试可能会阻塞，直到有空间存储所添加的项为止。
但是，当我查看一些IProducerConsumerCollection的实现(比如ConcurrentQueue )时，
浏览 5提问于2009-12-21得票数 19
回答已采纳
2回答
我使用FileSystemWatcher来捕捉每个created、changed、deleted和renamed对文件夹中任何文件的更改。
通过这些更改，我需要对这些文件的内容执行一个简单的校验和。简单地说，我打开一个filestream并将它传递给MD5类：
private byte[] calculateChecksum(string frl)
{
using (FileStream stream = File.Open(frl, FileMode.Open, FileAccess.Read, FileShare.ReadWrite))
{
return t
浏览 10提问于2015-12-03得票数 2
回答已采纳
我是java.util.concurrent包的新手。我正在试着写一些样本。下面是我的一些示例代码片段：
for (MyTask task : tasks) {
Future<Boolean> result = task.getResult();
try {
if (result.isCancelled()) {
logger.info("processResults(): cancelled: "+ ((MyTask) task).getName());
} else if (result.get() == false) {
浏览 0提问于2011-08-27得票数 1
回答已采纳
我需要单生产者，单消费者FIFO查询，因为
我需要按照他们收到的顺序处理信息。
我需要异步执行此操作，因为调用者在处理消息时不应该等待。
下一条消息处理只应在前一条消息处理完成后才开始。有时“接收”消息的频率高于“处理”消息的频率。但是，平均来说，我应该能够处理所有的消息，只是有时我必须“排队”包他们。
所以这就像TCP/IP --我认为，这里有一个生产者和一个消费者，有时你接收消息的速度比你能处理的要快，所以你必须查询它们。在订单很重要的地方，在打电话的人根本不感兴趣的地方，你怎么处理这些东西。
这听起来很容易，我可能会使用通用Queue，但我想为此使用BlockingC
浏览 3提问于2012-04-11得票数 7
回答已采纳
我有一个ASP.Net应用程序充当系统之间的接口，这些系统倾向于通过多个请求以突发方式发送数据，我希望启动一个后台任务来执行某些处理，但我真的希望只有一个后台任务来完成这个任务。我可以使用HostingEnvironment.QueueBackgroundWorkItem，但这将不加区分地为每个传入请求启动一个线程，这是一个问题。
当我启动一个后台进程时，我希望它对它所做的工作(在连接的数据库中)进行排队，然后检查是否有另一个后台进程正在运行。如果存在，则应该完成，因为另一个进程将处理排队的工作。如果没有其他后台进程正在运行，那么我希望它开始处理排队的工作，直到没有更多的工作要做，然后它将停止
浏览 1提问于2015-09-10得票数 1
回答已采纳
我想调整大小并异步保存一批下载的图像。做到这一点的最佳方法是什么？
目前，我在下载图片后调用此方法：
public void SaveToResizedBitmap(Bitmap pBitmap, int pWidth, int pHeight, string pOutputFileNameStr)
{
System.Drawing.Image origImage = pBitmap;
System.Drawing.Image origThumbnail = new Bitmap(pWidth, pHeight, origImage.PixelF
浏览 0提问于2014-09-15得票数 0
1回答
更新14-2016年11月-2016年，我看到一些答案(非常感谢)要求更多的细节.
语言：VB.Net / Framework: 4.5
亲爱的TPL专家们，我是任务处理库(TPL)的新手，希望得到以下方面的帮助：
我需要处理一个大文件(几十万条记录)。每个记录都是一个标签分隔的记录，最多有4个字段。
对于每次读取记录，我需要提取字段和调用asnyc任务来处理这些字段。
显然，我需要限制进程，只允许一次最多处理10记录，也就是说，一次最多启动10任务。
例如，如果我读取第一个10记录，那么将启动10任务。如果任何一个任务完成了，我将读取下一个记录并启动另一个任务，等等，直到文件结束。基本上，我
浏览 0提问于2016-11-08得票数 2
下面的代码是我正在尝试优化的代码的简化版本。
void Main()
{
var words = new List<string> {"abcd", "wxyz", "1234"};
foreach (var character in SplitItOut(words))
{
Console.WriteLine (character);
}
}
public IEnumerable<char> SplitItOut(IEnumerable<string> wo
浏览 0提问于2012-01-27得票数 3
回答已采纳
5回答
我有Class1，它有来自API的消息的事件侦听器。当接收到信号时，我希望将此消息发送到多个其他工作线程，这些线程处理该消息。在C#中实现这一点的最简单和最快的方法是什么？关于这个题目有什么好的教程吗？我主要关心的是如何尽可能快地将传入消息发送到工作线程，因为它们必须以尽可能快的速度响应API。
任何帮助都是很受欢迎的。
浏览 8提问于2014-01-24得票数 0
回答已采纳
好的，我有一个API，我想在应用程序启动的那一秒加载它，我初始化了请求。但我不会在任何地方调用异步任务，也不想使用按钮来执行此任务。我有自己的类，它将接受来自响应的数据，但我只希望将其移交给另一个方法，这样我就可以在那里使用它，而不必向用户显示数据。我该怎么做呢？这是我来自Mainwindow.xaml.cs和API.cs的代码 using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Wind
浏览 27提问于2019-12-30得票数 0
我正在使用第三方公共许可证支持在C#中实现多线程生产者-消费者模式。有了方便的BlockingCollection和Task类，这项工作就变得很简单，除非我需要处理异常。
众所周知，当BlockingCollection中没有可供消费的项目时，使用者Tasks对象将被阻塞，为了防止这些任务无限等待，调用BlockingCollection.CompleteAdding()显式地告诉每个人没有项目添加到BlockingCollection并唤醒任何正在等待的任务是至关重要的。
在我的例子中，在启动多个使用者和调用BlockingCollection.CompleteAdding()之间，可能会抛
浏览 3提问于2010-09-21得票数 1
回答已采纳
我正在编写一个服务，该服务必须从AMQP消息队列中读取任务，并根据消息类型执行同步操作。这些操作可能是发送电子邮件或访问web服务，但通常需要几百毫秒，假设没有错误。
我希望这是可扩展的，以便以后可以添加其他操作。无论哪种方式，信息的数量都可能相当大，每秒钟都会有100秒的突发信息。
我在玩几种设计，但我的问题如下：
我应该选择什么样的线程模式？我是否：
- a) Go with a single thread to consume from the queue and put tasks on a thread pool? If so, how do I represent th
浏览 1提问于2014-08-23得票数 1
回答已采纳
2回答
线程能跳过lock()吗？
、、、、
我有一个class，它提供对LinkedList<>的线程安全访问(添加和读取项)。
class LinkedListManager {
public static object locker = new object();
public static LinkedList<AddXmlNodeArgs> tasks { get; set; }
public static EventWaitHandle wh { get; set; }
public void AddItemThreadSafe(AddXmlNodeArgs task)
浏览 1提问于2014-07-29得票数 1
4回答
我最近听了很多关于.NET 4.0中的第三方公共关系的播客。它们中的大多数描述了后台活动，如下载图像或进行计算，使用任务以使工作不会干扰GUI线程。
我工作的大多数代码都具有多生产者/单消费者的风格，其中来自多个来源的工作项必须排队，然后按顺序进行处理。一个例子是日志记录，其中来自多个线程的日志行被序列化为单个队列，以便最终写入文件或数据库。来自任何单个源的所有记录都必须保持有序，并且来自同一时刻的记录在最终输出中应该彼此“接近”。
因此，多个线程或任务或其他什么都在调用队列程序：
lock( _queue ) // or use a lock-free queue!
{
_queue.
浏览 3提问于2010-02-19得票数 16
回答已采纳
2回答
我们已经开发了一个使用多线程侦听器概念的vb.net应用程序，每个文件夹都有一个专门的线程来监控。这样，我们可以同时跟踪每个文件夹中的传入文件。
目前，每当我们收到多个批量文件时，我们都面临着一个问题，并行处理的文件会因为线程概念而延迟或有时会失败。我们需要用其他的概念来实现相同的逻辑，避免多线程。请提供您对此的建议。或者，是否可以使用相同的线程概念来实现性能调优？请给我引路。
浏览 3提问于2011-04-26得票数 2
我有一个windows服务来处理链接列表队列中的xml文件。在创建文件时，队列中的文件是由FileSystemWatcher事件添加的。
namespace XMLFTP
{
public class XML_Processor : ServiceBase
{
public string s_folder { get; set; }
public XML_Processor(string folder)
{
s_folder = folder;
}
Thread worker;
浏览 1提问于2014-01-08得票数 1
回答已采纳
2回答
也许这个功能已经隐藏在.NET框架中的某个地方了，但是我找不到它。我需要按照给定的顺序一个接一个地执行方法。这些方法应该返回一些东西(例如object)，因此有一种方法可以对返回的数据做出反应(例如，由于发生错误而取消执行以下方法)。方法的执行应该在它自己的线程中运行，我应该能够在任何时候将方法添加到队列中。你知道如何在c#中实现这个功能吗？
多亏了Jon的评论，我试着自己实现这样一个队列。这可能是完全错误的-所以非常欢迎评论;-)
using System;
using System.Collections.Concurrent;
using System.Threading.Tasks;
浏览 0提问于2013-05-13得票数 0
2回答
我正在构建的一个应用程序从某个来源读取日志，并将其显示在网格上。日志的大小可以在几MB到几GB之间。为了防止任何内存问题，我使用了一个网格，一次对日志500行进行分页。这就是我希望做的：
我想创建一个线程，它将读取日志并将它们写入到一个文件中，每次大约500行，然后向另一个线程发出日志已经写入的信号。然后，另一个线程将读取该文件，并在网格上显示这些行，并向第一个线程发出它已完成读取的信号。这会一直持续下去，直到不再有日志要写入文件为止。
可以像这样在线程之间切换吗？
浏览 1提问于2012-06-01得票数 1
回答已采纳
2回答
限制正在运行的并发任务总数
、、、、
我有一个Create方法，只要在服务总线消息队列()上看到新消息，就会执行该方法。
我正在尝试将所有Create调用可以并行运行的并发任务总数限制为5个任务。
在我的代码中，Parallel.ForEach似乎什么也不做。
我尝试在makePdfAsync()调用周围添加一个互斥/锁，如下所示：
mutex.WaitOne();
if(curretNumTasks < MaxTasks)
{
tasks.Add(makePdfAsync(form));
}
mutex.ReleaseMutex();
但是它非常慢，并且使服务总线抛出。
如何限制所有Create调用创建的并发任务的
浏览 0提问于2017-05-12得票数 0
我正在尝试使用Monitor在C#中实现一个生产者/消费者类。想法是，消费者必须阻止，直到生产者有一些商品给消费者，但生产者应该继续生产。我的生产者生产了一些产品，然后在再次生产之前等待/休眠了一段时间。
我看到的问题是制作人永远不会从Thread.Sleep(time)中醒来。也许在某个地方出现了死锁的情况。
请帮助我理解这一点。
顺便说一句，我不想用BlockingCollection ...这是我的代码。
public class ProducerConsumerEx
{
private object _objLocker = new object();
浏览 3提问于2016-09-22得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
