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);
原文地址:https://blog.csdn.net/a876106354/article/details/140369742
免责声明:本站文章内容转载自网络资源,如本站内容侵犯了原著者的合法权益,可联系本站删除。更多内容请关注自学内容网(zxcms.com)!