ArrayPool.Shared解说

技术分享 6个月前 (09-29) 0 999+

ArrayPool简介

.NET 中频繁创建和销毁数组的情况下会导致垃圾回收器出现严重的内存压力，ArrayPool<T> 通过池化手段有效地降低了数组的分配和垃圾回收器的回收压力，同时 ArrayPool<T> 也是 MemoryPool<T> 和 PipeWriter、PipeReader 的底板。

ArrayPool<T>.Shared 是 ArrayPool<T> 的一种实现，它设计成静态共享以供全体共同使用。在实际应用中， Shared 实例几乎承载了全部的 ArrayPool<T> 调用。

Shared实例的Rent

static void RentAndReturn(int size) {     var pool = ArrayPool<byte>.Shared;     var array = pool.Rent(size);      // 在这里使用 array      pool.Return(array);  }

其中输入的 size 和 Rent 得到 array.Length的关系如下：

var index = SelectBucketIndex(size); var arrayLenth = GetMaxSizeForBucket(index);  static int SelectBucketIndex(int size) {    return BitOperations. Log2((uint)((size - 1) | 0xF)) - 3;              }  static int GetMaxSizeForBucket(int bucketIndex) {    return 16 << bucketIndex; }

调用 SelectBucketIndex(int.MaxValue) 会得到27，实际上 Shared 实现只维护最大索引值为 26 的总共 27 个 Bucket，所以当你 Rent 出大于 1GB 的数组时永远触发分配且不会 Return 到 Bucket 里。

Shared实例的Return

如果我们书写如下代码，会发生什么情况？

var pool = ArrayPool<byte>.Shared;  var array1 = new byte[16]; pool.Return(array1);  var array2 = new byte[16]; pool.Return(array2);

array1 和 array2 都不是 Rent 出来的，Return 操作 pool 会接受吗？
答案是都接受，只要 array.Length 符合要求都会接受，而且也不会考虑多次 Return 同一个引用 array 的特殊情况。所以千万不要对同一个 Rent 到的 array 实例进行多次 return 操作。

Shared实例的Thread-Local-Storage

如果我们书写如下代码，会触发 Shared 的 Buckets 读写访问吗？

var pool = ArrayPool<byte>.Shared; for(var i =0; i <100; i++) {     var array = pool.Rent(1024 * 1024);     pool.Return(array); }

答案是不会触发 Buckets 读写访问，执行之后 27 个 Bucket 还是未初始化的 null 值，因为Shared使用Thread-Local-Storage做了第一层无锁缓存。

原始代码

[ThreadStatic] private static SharedArrayPoolThreadLocalArray[]? t_tlsBuckets;

方便理解的简化代码

// 创建一个 Array 类型的数组，数组共27个元素 // 每个元素的索引值，对应 Bucket 的索引 [ThreadStatic] private static Array? [] t_tlsBuckets = new Array[27];

当执行

var array = ArrayPool<byte>.Shared.Rent(16);

实际的逻辑是

var index = SelectBucketIndex(16); // index = 0; var array = t_tlsBuckets[index];   if(array != null) {     t_tlsBuckets[index] = null;  // 当然这里不会对t_tlsBuckets进行2次索引访问，使用 ref 来解决     return array; }

Return 的时候也是一样的缓存访问逻辑，当 t_tlsBuckets 索引对应的元素为 null 时缓存成功。

Shared实例的Buckets

当 t_tlsBuckets[index] 缓存不命中时，会触发 Bucket = Buckets[index] 的创建和访问。注意这里一个 Bucket 不是 Array的集合，而是Array的集合的集合，我们叫他Partitions。为了方便理解，下面给出示意代码：

// bucket 是 Partition 的集合，Partition 是 Array 的集合 // bucket 的元素数量是 Environment.ProcessorCount List<Partition> bucket = Buckets[index];  Debug.Assert(bucket.Count == Environment.ProcessorCount);

当进行 Rent 操作时，尝试从 bucket 里弹出一个 Array，其示意过程如下（注意真实的实现为高性能代码可理解性更难）：

// bucket 是 Partition 的集合，Partition 是 Array 的集合 // bucket 的元素数量是 Environment.ProcessorCount List<Partition> bucket = Buckets[index];  // 每个 cpu 核心操作固定的一个 Partition，目的是去锁化 int cpuIndex = Thread.GetCurrentProcessorId() % Environment.ProcessorCount; Partition cpuPartition = bucket[cpuIndex];  // Partition 的元素数量固定是 32 Debug.Assert(cpuPartition.Count == 32);  // 尝试从当前 cpu 核心对应的 Partition 进行TryPop() // TryPop() 的实现有排他锁，但这里只要没有别的线程来访问此 Partition,就不会产生互斥 // 如果在同一线程下租赁过32次且不归还，TryPop()会失败 Array array = null; if ((array = cpuPartition.TryPop()) != null) {     return array; })  // 以上失败后则尝试从其它的 Partition TryPop()，此时排他锁可能就生效了 for(var index = 0; index < bucket.Count; index++) {     if(index!= cpuIndex)     {         Partition otherPartition = bucket[index];         if ((array = otherPartition.TryPop()) != null)         {             return array;         })     } }  return null;

在进行 Return 操作是，大的流程和 Rent 一样，不同是 TryPop() 变成了TryPush()。
总结一下，在指定 size 之后，Shared 实例最多能 Rent(size) 出 Environment.ProcessorCount * 32 个可复用的数组，伴随着 Return 的及时性越低，Rent 时排它锁触发的几率就越高。