99 lines
2.6 KiB
Markdown
99 lines
2.6 KiB
Markdown
|
#unity/日常积累
|
|||
|
|
|
|||
|
|
# ConcurrentQueue 类
|
|||
|
|
|
|||
|
|
- 参考
|
|||
|
|
|
|||
|
|
反馈
|
|||
|
|
|
|||
|
|
[](https://learn.microsoft.com/zh-cn/dotnet/api/system.collections.concurrent.concurrentqueue-1?view=net-8.0#definition)
|
|||
|
|
|
|||
|
|
## 定义
|
|||
|
|
|
|||
|
|
命名空间:
|
|||
|
|
|
|||
|
|
[System.Collections.Concurrent](https://learn.microsoft.com/zh-cn/dotnet/api/system.collections.concurrent?view=net-8.0)
|
|||
|
|
|
|||
|
|
程序集:
|
|||
|
|
|
|||
|
|
System.Collections.Concurrent.dll
|
|||
|
|
|
|||
|
|
表示线程安全的先进先出 (FIFO) 集合。
|
|||
|
|
|
|||
|
|
``` cs
|
|||
|
|
public class ConcurrentQueue<T> : System.Collections.Concurrent.IProducerConsumerCollection<T>, System.Collections.Generic.IEnumerable<T>, System.Collections.Generic.IReadOnlyCollection<T>, System.Collections.ICollection
|
|||
|
|
```
|
|||
|
|
|
|||
|
|
#### 类型参数
|
|||
|
|
|
|||
|
|
T
|
|||
|
|
|
|||
|
|
队列中包含的元素的类型。
|
|||
|
|
|
|||
|
|
继承
|
|||
|
|
|
|||
|
|
[Object](https://learn.microsoft.com/zh-cn/dotnet/api/system.object?view=net-8.0)
|
|||
|
|
|
|||
|
|
``` cs
|
|||
|
|
ConcurrentQueue<T>
|
|||
|
|
```
|
|||
|
|
|
|||
|
|
示例
|
|||
|
|
|
|||
|
|
``` cs
|
|||
|
|
using System;
|
|||
|
|
using System.Collections.Concurrent;
|
|||
|
|
using System.Threading;
|
|||
|
|
using System.Threading.Tasks;
|
|||
|
|
|
|||
|
|
class CQ_EnqueueDequeuePeek
|
|||
|
|
{
|
|||
|
|
// Demonstrates:
|
|||
|
|
// ConcurrentQueue<T>.Enqueue()
|
|||
|
|
// ConcurrentQueue<T>.TryPeek()
|
|||
|
|
// ConcurrentQueue<T>.TryDequeue()
|
|||
|
|
static void Main ()
|
|||
|
|
{
|
|||
|
|
// Construct a ConcurrentQueue.
|
|||
|
|
ConcurrentQueue<int> cq = new ConcurrentQueue<int>();
|
|||
|
|
|
|||
|
|
// Populate the queue.
|
|||
|
|
for (int i = 0; i < 10000; i++)
|
|||
|
|
{
|
|||
|
|
cq.Enqueue(i);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
// Peek at the first element.
|
|||
|
|
int result;
|
|||
|
|
if (!cq.TryPeek(out result))
|
|||
|
|
{
|
|||
|
|
Console.WriteLine("CQ: TryPeek failed when it should have succeeded");
|
|||
|
|
}
|
|||
|
|
else if (result != 0)
|
|||
|
|
{
|
|||
|
|
Console.WriteLine("CQ: Expected TryPeek result of 0, got {0}", result);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
int outerSum = 0;
|
|||
|
|
// An action to consume the ConcurrentQueue.
|
|||
|
|
Action action = () =>
|
|||
|
|
{
|
|||
|
|
int localSum = 0;
|
|||
|
|
int localValue;
|
|||
|
|
while (cq.TryDequeue(out localValue)) localSum += localValue;
|
|||
|
|
Interlocked.Add(ref outerSum, localSum);
|
|||
|
|
};
|
|||
|
|
|
|||
|
|
// Start 4 concurrent consuming actions.
|
|||
|
|
Parallel.Invoke(action, action, action, action);
|
|||
|
|
|
|||
|
|
Console.WriteLine("outerSum = {0}, should be 49995000", outerSum);
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
```
|
|||
|
|
|
|||
|
|
## 注解
|
|||
|
|
|
|||
|
|
备注
|
|||
|
|
|
|||
|
|
[ConcurrentQueue<T>](https://learn.microsoft.com/zh-cn/dotnet/api/system.collections.concurrent.concurrentqueue-1?view=net-8.0)[IReadOnlyCollection<T>](https://learn.microsoft.com/zh-cn/dotnet/api/system.collections.generic.ireadonlycollection-1?view=net-8.0)实现从 .NET Framework 4.6 开始的接口;在.NET Framework的早期版本中，[ConcurrentQueue<T>](https://learn.microsoft.com/zh-cn/dotnet/api/system.collections.concurrent.concurrentqueue-1?view=net-8.0)类未实现此接口。
|