。

传统QueueT在并发场景下需要手动加锁#xff0c;而ConcurrentQueueT作为.NET

Framework

引入的线程安全集合数据共享如同走钢丝——稍有不慎就会引发竞态条件Race

Condition或死锁。

传统QueueT在并发场景下需要手动加锁而ConcurrentQueueT作为.NET

Framework

引入的线程安全集合采用无锁算法Lock-Free能显著提升高并发场景下的性能。

今天我们就来深入探讨一下

ConcurrentQueueT

命名空间。

它遵循先进先出FIFO的原则允许多个线程同时对队列进行操作而无需额外的锁机制。

用于在生产者和消费者场景中高效地处理数据。

但需要注意的是它并不保证元素在同一个线程内入队顺序和出队顺序完全一致。

核心特性速览

无锁设计通过CASCompare-And-Swap原子操作实现高效并发

无锁编程ConcurrentQueueT

使用了无锁编程技术减少了锁的开销提高了性能。

原子操作队列的入队和出队操作是原子性的这意味着即使在多线程环境下操作也不会被打断

FIFO原则先进先出但线程间顺序不绝对保证在多线程环境下队列的顺序可能会受到线程调度的影响。

高吞吐量实测在16线程并发下吞吐量可达普通锁队列的3倍内存高效采用链表结构动态扩展避免数组复制的开销

性能对比基准测试

操作类型ConcurrentQueueQueueLock100万次入队45

ms210

消费者模式中多个生产者线程同时向队列中放入任务元素多个消费者线程从队列中取出任务执行。

ConcurrentQueue可以完美适配这种场景确保数据的安全传递和并发操作的效率。

例如多个网络请求到达服务器生产者服务器将这些请求放入ConcurrentQueue然后多个工作线程从队列中取出请求进行处理消费者。

任务调度系统

当需要调度多个任务按照顺序执行时ConcurrentQueue可以用来存储任务的顺序。

多个调度器线程可以从队列中取出任务并分配到合适的资源上执行保证任务的有序性和并发性。

二、基本操作

queue.Enqueue(2);在多线程环境下多个线程可以同时调用Enqueue方法而不需要担心数据冲突问题。

多线程安全添加

TryDequeue方法尝试从队列中取出一个元素。

示例代码如下

int

}如果队列中有元素TryDequeue会成功取出元素并将队列修改为相应的状态返回true如果队列为空则返回falsevalue保持其初始值。

这一特性使得它在多线程并发访问队列时非常方便不需要像普通队列那样额外进行线程同步处理。

查看队首元素TryPeek

TryPeek方法可以查看队列的第一个元素而不将其移除队列。

例如

ConcurrentQueueint

尝试在不枚举集合的情况下获取元素数量对于实现了ICollection接口的类型如ConcurrentQueueT、ConcurrentBagT直接返回Count属性值避免某些集合类型如普通IEnumerable需要枚举才能计数的性能损耗

特性TryGetNonEnumeratedCountCount

属性适用范围所有IEnumerable类型具体集合类型返回值类型bool是否成功获取int直接返回数量实现机制通过接口检查优化路径直接访问内部计数器对未实现ICollection的集合可能返回false并需要枚举不可用

var

(queue.TryGetNonEnumeratedCount(out

int

{Console.WriteLine($Non-enumerated

count:

}对于ConcurrentQueueT两种方式本质相同。

但在编写通用集合处理代码时TryGetNonEnumeratedCount能更好地兼容各种集合类型避免对未实现ICollection接口的集合进行低效枚举

其他操作

QueueT可能会引发线程安全问题。

例如当多个线程同时对队列进行读写操作时可能会导致数据丢失、异常或程序崩溃。

而

ConcurrentQueueT

会导致数据丢失或抛出异常});Console.WriteLine($非安全集合数量:

运行结果

1000甚至可能抛出异常。

结果不确定由于线程竞争是随机的每次运行的结果可能不同。

为什么不安全

是普通的先进先出FIFO集合但不保证多线程并发操作的安全性。

当多个线程同时调用

Enqueue()

_tail导致写入位置冲突部分数据被覆盖。

容量扩展竞争当队列需要扩容时多个线程可能同时触发内部数组的重新分配导致数据丢失或数组损坏。

计数不一致Count

Parallel.For

强制串行化写入unsafeQueue.Enqueue(i);}

Enqueue

在普通的QueueT中如果不是线程安全的环境在多线程同时进行入队和出队操作时可能会产生数据混乱等问题需要手动进行加锁等操作来保证线程安全。

而ConcurrentQueueT是线程安全的不需要额外的锁操作就能正确处理并发情况。

性能优势

在高并发场景下ConcurrentQueue的非阻塞算法无锁相比使用锁的传统队列有更好的性能。

例如普通使用锁的入队和出队操作如下代码在高并发时会导致线程频繁阻塞和唤醒而ConcurrentQueue通过原子操作避免了线程阻塞提高了并发处理效率。

public

(_lock){_queue.Enqueue(item);}}public

bool

i){queue.Enqueue(i);Console.WriteLine($Enqueued:

{i});}});//

result)){Console.WriteLine($Dequeued:

{result});}}});Task.WaitAll(producer,

consumer);}

}在这个示例中生产者线程负责向队列中添加数据消费者线程负责从队列中移除数据。

由于

ConcurrentQueueT

(!_cts.IsCancellationRequested){var

data

ReceiveNetworkPacket();_queue.Enqueue(data);}});//

consumerCount,

(_cts.IsCancellationRequested){break;}else{SpinWait.SpinUntil(()

!_queue.IsEmpty

_cts.IsCancellationRequested);}}});}public

void

ReadSensor();dataQueue.Enqueue(data);Thread.Sleep(100);}

});//

message)){writer.WriteLine($[{DateTime.UtcNow:O}]

{message});}writer.Flush();}});}public

static

message){_logQueue.Enqueue(message);_signal.Set();}

}五、注意事项

虽然ConcurrentQueue遵循FIFO原则但是由于并发操作的存在同一个线程内先入队的元素可能会后出队。

在编写代码时需要考虑到这种情况避免对元素顺序有过于严格的预期。

虽然号称FIFO但在以下场景可能出现顺序异常

线程A

在高频率入队和出队操作中要注意内存的使用情况因为队列中的元素可能会随着时间不断积累如果没有及时消费可能会导致内存占用过高。

对象池模式复用出队对象减少GC压力容量监控定期检查cq.Count设置阈值报警

对象池示例

当需要线程安全的先进先出集合时ConcurrentQueueT通常是首选。

但在以下场景需考虑替代方案

优先级队列

特性ConcurrentQueueBlockingCollectionChannels阻塞操作❌✔️✔️

(.NET

Core)边界控制❌✔️✔️内存效率高中高适用场景非阻塞队列有界集合异步管道

回到目录页C#/.NET