我在用 c# 编写异步多服务器网络应用程序时遇到了问题。我有许多工作由线程池处理，其中包括对网络套接字的写入。这最终允许了多个线程可以同时写入套接字并混淆我的传出消息的情况。我解决这个问题的想法是实现一个队列系统，只要数据被添加到队列中，套接字就会写入它。
我的问题是，我无法完全理解这种性质的架构。我想象有一个队列对象在数据被添加到队列时触发一个事件。然后该事件将写入队列中保存的数据，但这不起作用，因为如果两个线程同时到达并添加到队列中，即使队列被设为线程安全，事件仍然会为两者触发，并且我会遇到同样的问题。因此，如果另一个事件正在进行中，那么可能会以某种方式推迟一个事件，但是一旦第一个事件完成，我该如何继续该事件，而不会简单地阻塞某个互斥锁或其他东西上的线程。如果我不尝试严格遵守“无阻塞”架构，这不会那么难，但是这个特定的应用程序要求我允许线程池线程继续做他们的事情。
有什么想法吗？
【问题讨论】：
标签： c# architecture asynchronous queue asyncsocket
虽然类似于 Porges 的回答，但在实现上略有不同。
首先，我通常不对要发送的字节进行排队，而是在发送线程中将对象和序列化，但我想这是一个品味问题。 但更大的区别在于 ConcurrentQueues 的使用（除了 BlockingCollection）。 所以我最终会得到类似于
的代码 BlockingCollection<Packet> sendQueue = new BlockingCollection<Packet>(new ConcurrentQueue<Packet>());
while (true)
{
var packet = sendQueue.Take(); //this blocks if there are no items in the queue.
SendPacket(packet); //Send your packet here.
}
这里的关键是您有一个循环此代码的线程，所有其他线程都可以以线程安全的方式添加到队列中（BlockingCollection 和 ConcurrentQueue 都是线程安全的）
看看Processing a queue of items asynchronously in C# 我回答了类似的问题。
【讨论】：
new BlockingCollection<Packet>(new ConcurrentQueue<Packet>()) 完全等同于 new BlockingCollection<Packet>() :)
听起来您需要一个线程同步写入套接字，而一堆线程写入队列以供该线程处理。
您可以使用阻塞集合 (BlockingCollection<T>) 来完成这项艰巨的工作：
// somewhere there is a queue:
BlockingCollection<byte[]> queue = new BlockingCollection<byte[]>();
// in socket-writing thread, read from the queue and send the messages:
foreach (byte[] message in queue.GetConsumingEnumerable())
{
// just an example... obviously you'd need error handling and stuff here
socket.Send(message);
}
// in the other threads, just enqueue messages to be sent:
queue.Add(someMessage);
BlockingCollection 将处理所有同步。您还可以强制执行最大队列长度和其他有趣的事情。
【讨论】：
我不懂 C#，但我会做的是让事件触发套接字管理器开始从队列中拉出并一次写出一个。如果它已经在运行，则触发器不会执行任何操作，一旦队列中没有任何内容，它就会停止。
这解决了两个线程同时写入队列的问题，因为第二个事件将是空操作。
【讨论】：
您可以有一个线程安全队列，您的所有工作线程都将其结果写入其中。然后让另一个线程轮询队列并在看到队列等待时发送结果。
【讨论】：