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);
边界)
