C# 浅谈线程安全的集合ConcurrentQueue

ConcurrentQueue 是 C# 中另一个线程安全的集合，它位于 System.Collections.Concurrent 命名空间中。 Enqueue(T item): 向队列的末尾添加一个元素。如果操作成功，则返回 true。 TryDequeue(out T result): 尝试从队列的开头移除并返回一个元素。如果队列为空，则不执行任何操作并返回 false；如果成功移除并返回元素，则返回 true。 IsEmpty: 一个属性，用于检查队列是否为空。 Clear(): 移除队列中的所有元素。

ConcurrentQueue queue = new ConcurrentQueue();

// 启动一个任务来向队列中添加数据 Task producerTask = Task.Run(() => {     for (int i = 1; i <= 10; i++)     {         queue.Enqueue(i);         Console.WriteLine($"Produced {i}");         Task.Delay(1000).Wait(); // 模拟生产数据的延迟     } });

// 启动一个任务来从队列中移除数据 Task consumerTask = Task.Run(() => {     while (true)     {         if (queue.TryDequeue(out int value))         {             Console.WriteLine($"Consumed {value}");         }         else         {             // 队列为空时退出循环             break;         }     } });

// 等待两个任务完成 Task.WaitAll(producerTask, consumerTask);