ObjectPool

DefaultObjectPool.cs (1)

15public class DefaultObjectPool<T> : ObjectPool<T> where T : class

LeakTrackingObjectPool.cs (1)

22public class LeakTrackingObjectPool<T> : ObjectPool<T> where T : class

Latency\Internal\ResetOnGetObjectPool.cs (1)

9internal sealed class ResetOnGetObjectPool<T> : ObjectPool<T>

Latency\Internal\LatencyContextTests.cs (1)

305private class MockResetOnGet : ObjectPool<LatencyContext>

Buffering\IncomingRequestLogBuffer.cs (1)

22private static readonly ObjectPool<List<DeserializedLogRecord>> _recordsToEmitListPool =

Latency\RequestLatencyTelemetryMiddleware.cs (2)

27private static readonly ObjectPool<List<Task>> _exporterTaskPool = PoolFactory.CreateListPool<Task>(); 28private static readonly ObjectPool<CancellationTokenSource> _cancellationTokenSourcePool = PoolFactory.CreateCancellationTokenSourcePool();

src\Shared\BufferWriterPool\BufferWriterPool.cs (2)

26public static ObjectPool<BufferWriter<T>> CreateBufferWriterPool<T>(int maxCapacity = DefaultCapacity, int maxBufferWriterCapacity = DefaultMaxBufferWriterCapacity) 37public static ObjectPool<BufferWriter<byte>> SharedBufferWriterPool { get; } = CreateBufferWriterPool<byte>();

src\Shared\BufferWriterPool\ReturnableBufferWriter.cs (2)

20private readonly ObjectPool<BufferWriter<T>> _pool; 26public ReturnableBufferWriter(ObjectPool<BufferWriter<T>> pool)

RedactionBenchmark.cs (1)

23private readonly ObjectPool<StringBuilder> _stringBuilderPool;

src\Shared\Pools\PoolFactory.cs (10)

39public static ObjectPool<T> CreatePool<T>(int maxCapacity = DefaultCapacity) 54public static ObjectPool<T> CreatePool<T>(IPooledObjectPolicy<T> policy, int maxCapacity = DefaultCapacity) 72public static ObjectPool<T> CreateResettingPool<T>(int maxCapacity = DefaultCapacity) 86public static ObjectPool<StringBuilder> CreateStringBuilderPool(int maxCapacity = DefaultCapacity, int maxStringBuilderCapacity = DefaultMaxStringBuilderCapacity) 114public static ObjectPool<List<T>> CreateListPool<T>(int maxCapacity = DefaultCapacity) 132public static ObjectPool<List<T>> CreateListPoolWithCapacity<T>(int listCapacity, int maxCapacity = DefaultCapacity) 152public static ObjectPool<Dictionary<TKey, TValue>> CreateDictionaryPool<TKey, TValue>(IEqualityComparer<TKey>? comparer = null, int maxCapacity = DefaultCapacity) 171public static ObjectPool<HashSet<T>> CreateHashSetPool<T>(IEqualityComparer<T>? comparer = null, int maxCapacity = DefaultCapacity) 194public static ObjectPool<CancellationTokenSource> CreateCancellationTokenSourcePool(int maxCapacity = DefaultCapacity) 204public static ObjectPool<StringBuilder> SharedStringBuilderPool { get; } = CreateStringBuilderPool();

HeaderParsingFeature.cs (2)

88private readonly ObjectPool<PoolHelper> _pool; 91ObjectPool<PoolHelper> pool,

HeaderParsingServiceCollectionExtensions.cs (1)

32.AddScoped(provider => provider.GetRequiredService<ObjectPool<HeaderParsingFeature.PoolHelper>>().Get())

HeaderParsingFeatureTests.cs (1)

160var pool = new Mock<ObjectPool<HeaderParsingFeature.PoolHelper>>(MockBehavior.Strict);

Features\ResponseCookiesFeature.cs (2)

36/// <param name="builderPool">The <see cref="ObjectPool{T}"/>, if available.</param> 38public ResponseCookiesFeature(IFeatureCollection features, ObjectPool<StringBuilder>? builderPool)

HttpLoggingBuilderExtensions.cs (1)

49if (serviceProviderIsService != null && (!serviceProviderIsService.IsService(typeof(ObjectPool<HttpLoggingInterceptorContext>)) ||

HttpLoggingMiddleware.cs (4)

20private readonly ObjectPool<HttpLoggingInterceptorContext> _contextPool; 21private readonly ObjectPool<ResponseBufferingStream> _responseBufferingStreamPool; 28IEnumerable<IHttpLoggingInterceptor> interceptors, ObjectPool<HttpLoggingInterceptorContext> contextPool, 29ObjectPool<ResponseBufferingStream> responseBufferingStreamPool, TimeProvider timeProvider)

NewtonsoftJsonInputFormatter.cs (1)

28private ObjectPool<JsonSerializer>? _jsonSerializerPool;

OutputCacheKeyProvider.cs (1)

20private readonly ObjectPool<StringBuilder> _builderPool;

ResponseCachingKeyProvider.cs (1)

19private readonly ObjectPool<StringBuilder> _builderPool;

DependencyInjection\RoutingServiceCollectionExtensions.cs (3)

51services.TryAddSingleton<ObjectPool<UriBuildingContext>>(s => 62var objectPool = s.GetRequiredService<ObjectPool<UriBuildingContext>>();

Template\DefaultTemplateBinderFactory.cs (2)

13private readonly ObjectPool<UriBuildingContext> _pool; 17ObjectPool<UriBuildingContext> pool)

Template\TemplateBinder.cs (6)

22private readonly ObjectPool<UriBuildingContext> _pool; 40/// <param name="pool">The <see cref="ObjectPool{T}"/>.</param> 45ObjectPool<UriBuildingContext> pool, 56/// <param name="pool">The <see cref="ObjectPool{T}"/>.</param> 65ObjectPool<UriBuildingContext> pool, 97ObjectPool<UriBuildingContext> pool,

Tree\TreeRouteBuilder.cs (3)

34private readonly ObjectPool<UriBuildingContext> _objectPool; 43/// <param name="objectPool">The <see cref="ObjectPool{UrlBuildingContext}"/>.</param> 49ObjectPool<UriBuildingContext> objectPool,

Tree\TreeRouter.cs (2)

50/// <param name="objectPool">The <see cref="ObjectPool{T}"/>.</param> 59ObjectPool<UriBuildingContext> objectPool,

Internal\NamedPipeConnectionListener.cs (1)

23private readonly ObjectPool<NamedPipeServerStream> _namedPipeServerStreamPool;

AsyncState.cs (1)

16private static readonly ObjectPool<List<object?>> _featuresPool = PoolFactory.CreatePool(new FeaturesPooledPolicy());

src\Shared\Pools\PoolFactory.cs (10)

39public static ObjectPool<T> CreatePool<T>(int maxCapacity = DefaultCapacity) 54public static ObjectPool<T> CreatePool<T>(IPooledObjectPolicy<T> policy, int maxCapacity = DefaultCapacity) 72public static ObjectPool<T> CreateResettingPool<T>(int maxCapacity = DefaultCapacity) 86public static ObjectPool<StringBuilder> CreateStringBuilderPool(int maxCapacity = DefaultCapacity, int maxStringBuilderCapacity = DefaultMaxStringBuilderCapacity) 114public static ObjectPool<List<T>> CreateListPool<T>(int maxCapacity = DefaultCapacity) 132public static ObjectPool<List<T>> CreateListPoolWithCapacity<T>(int listCapacity, int maxCapacity = DefaultCapacity) 152public static ObjectPool<Dictionary<TKey, TValue>> CreateDictionaryPool<TKey, TValue>(IEqualityComparer<TKey>? comparer = null, int maxCapacity = DefaultCapacity) 171public static ObjectPool<HashSet<T>> CreateHashSetPool<T>(IEqualityComparer<T>? comparer = null, int maxCapacity = DefaultCapacity) 194public static ObjectPool<CancellationTokenSource> CreateCancellationTokenSourcePool(int maxCapacity = DefaultCapacity) 204public static ObjectPool<StringBuilder> SharedStringBuilderPool { get; } = CreateStringBuilderPool();

src\Shared\Pools\PoolFactory.cs (10)

39public static ObjectPool<T> CreatePool<T>(int maxCapacity = DefaultCapacity) 54public static ObjectPool<T> CreatePool<T>(IPooledObjectPolicy<T> policy, int maxCapacity = DefaultCapacity) 72public static ObjectPool<T> CreateResettingPool<T>(int maxCapacity = DefaultCapacity) 86public static ObjectPool<StringBuilder> CreateStringBuilderPool(int maxCapacity = DefaultCapacity, int maxStringBuilderCapacity = DefaultMaxStringBuilderCapacity) 114public static ObjectPool<List<T>> CreateListPool<T>(int maxCapacity = DefaultCapacity) 132public static ObjectPool<List<T>> CreateListPoolWithCapacity<T>(int listCapacity, int maxCapacity = DefaultCapacity) 152public static ObjectPool<Dictionary<TKey, TValue>> CreateDictionaryPool<TKey, TValue>(IEqualityComparer<TKey>? comparer = null, int maxCapacity = DefaultCapacity) 171public static ObjectPool<HashSet<T>> CreateHashSetPool<T>(IEqualityComparer<T>? comparer = null, int maxCapacity = DefaultCapacity) 194public static ObjectPool<CancellationTokenSource> CreateCancellationTokenSourcePool(int maxCapacity = DefaultCapacity) 204public static ObjectPool<StringBuilder> SharedStringBuilderPool { get; } = CreateStringBuilderPool();

src\Shared\Pools\PoolFactory.cs (10)

39public static ObjectPool<T> CreatePool<T>(int maxCapacity = DefaultCapacity) 54public static ObjectPool<T> CreatePool<T>(IPooledObjectPolicy<T> policy, int maxCapacity = DefaultCapacity) 72public static ObjectPool<T> CreateResettingPool<T>(int maxCapacity = DefaultCapacity) 86public static ObjectPool<StringBuilder> CreateStringBuilderPool(int maxCapacity = DefaultCapacity, int maxStringBuilderCapacity = DefaultMaxStringBuilderCapacity) 114public static ObjectPool<List<T>> CreateListPool<T>(int maxCapacity = DefaultCapacity) 132public static ObjectPool<List<T>> CreateListPoolWithCapacity<T>(int listCapacity, int maxCapacity = DefaultCapacity) 152public static ObjectPool<Dictionary<TKey, TValue>> CreateDictionaryPool<TKey, TValue>(IEqualityComparer<TKey>? comparer = null, int maxCapacity = DefaultCapacity) 171public static ObjectPool<HashSet<T>> CreateHashSetPool<T>(IEqualityComparer<T>? comparer = null, int maxCapacity = DefaultCapacity) 194public static ObjectPool<CancellationTokenSource> CreateCancellationTokenSourcePool(int maxCapacity = DefaultCapacity) 204public static ObjectPool<StringBuilder> SharedStringBuilderPool { get; } = CreateStringBuilderPool();

Linux\Disk\DiskStatsReader.cs (1)

19private static readonly ObjectPool<BufferWriter<char>> _sharedBufferWriterPool = BufferWriterPool.CreateBufferWriterPool<char>();

Linux\LinuxUtilizationParserCgroupV1.cs (1)

20private static readonly ObjectPool<BufferWriter<char>> _sharedBufferWriterPool = BufferWriterPool.CreateBufferWriterPool<char>();

Linux\LinuxUtilizationParserCgroupV2.cs (1)

28private static readonly ObjectPool<BufferWriter<char>> _sharedBufferWriterPool = BufferWriterPool.CreateBufferWriterPool<char>();

Linux\Network\LinuxNetworkUtilizationParser.cs (1)

18private static readonly ObjectPool<BufferWriter<char>> _sharedBufferWriterPool = BufferWriterPool.CreateBufferWriterPool<char>();

src\Shared\BufferWriterPool\BufferWriterPool.cs (2)

26public static ObjectPool<BufferWriter<T>> CreateBufferWriterPool<T>(int maxCapacity = DefaultCapacity, int maxBufferWriterCapacity = DefaultMaxBufferWriterCapacity) 37public static ObjectPool<BufferWriter<byte>> SharedBufferWriterPool { get; } = CreateBufferWriterPool<byte>();

src\Shared\BufferWriterPool\ReturnableBufferWriter.cs (2)

20private readonly ObjectPool<BufferWriter<T>> _pool; 26public ReturnableBufferWriter(ObjectPool<BufferWriter<T>> pool)

src\Shared\Pools\PoolFactory.cs (10)

39public static ObjectPool<T> CreatePool<T>(int maxCapacity = DefaultCapacity) 54public static ObjectPool<T> CreatePool<T>(IPooledObjectPolicy<T> policy, int maxCapacity = DefaultCapacity) 72public static ObjectPool<T> CreateResettingPool<T>(int maxCapacity = DefaultCapacity) 86public static ObjectPool<StringBuilder> CreateStringBuilderPool(int maxCapacity = DefaultCapacity, int maxStringBuilderCapacity = DefaultMaxStringBuilderCapacity) 114public static ObjectPool<List<T>> CreateListPool<T>(int maxCapacity = DefaultCapacity) 132public static ObjectPool<List<T>> CreateListPoolWithCapacity<T>(int listCapacity, int maxCapacity = DefaultCapacity) 152public static ObjectPool<Dictionary<TKey, TValue>> CreateDictionaryPool<TKey, TValue>(IEqualityComparer<TKey>? comparer = null, int maxCapacity = DefaultCapacity) 171public static ObjectPool<HashSet<T>> CreateHashSetPool<T>(IEqualityComparer<T>? comparer = null, int maxCapacity = DefaultCapacity) 194public static ObjectPool<CancellationTokenSource> CreateCancellationTokenSourcePool(int maxCapacity = DefaultCapacity) 204public static ObjectPool<StringBuilder> SharedStringBuilderPool { get; } = CreateStringBuilderPool();

Latency\Internal\HttpClientLatencyLogEnricher.cs (1)

24private static readonly ObjectPool<StringBuilder> _builderPool = PoolFactory.SharedStringBuilderPool;

Logging\Internal\HttpClientLogger.cs (2)

24private readonly ObjectPool<List<KeyValuePair<string, string>>> _headersPool = 27private readonly ObjectPool<LogRecord> _logRecordPool =

src\Shared\BufferWriterPool\BufferWriterPool.cs (2)

26public static ObjectPool<BufferWriter<T>> CreateBufferWriterPool<T>(int maxCapacity = DefaultCapacity, int maxBufferWriterCapacity = DefaultMaxBufferWriterCapacity) 37public static ObjectPool<BufferWriter<byte>> SharedBufferWriterPool { get; } = CreateBufferWriterPool<byte>();

src\Shared\BufferWriterPool\ReturnableBufferWriter.cs (2)

20private readonly ObjectPool<BufferWriter<T>> _pool; 26public ReturnableBufferWriter(ObjectPool<BufferWriter<T>> pool)

Internal\RequestMessageSnapshot.cs (1)

15private static readonly ObjectPool<RequestMessageSnapshot> _snapshots = PoolFactory.CreateResettingPool<RequestMessageSnapshot>();

Routing\Internal\OrderedGroups\OrderedGroupsRoutingStrategy.cs (2)

15private readonly ObjectPool<OrderedGroupsRoutingStrategy> _pool; 19public OrderedGroupsRoutingStrategy(Randomizer randomizer, ObjectPool<OrderedGroupsRoutingStrategy> pool)

Routing\Internal\OrderedGroups\OrderedGroupsRoutingStrategyFactory.cs (1)

14private readonly ObjectPool<OrderedGroupsRoutingStrategy> _pool;

Routing\Internal\WeightedGroups\WeightedGroupsRoutingStrategy.cs (2)

16private readonly ObjectPool<WeightedGroupsRoutingStrategy> _pool; 21public WeightedGroupsRoutingStrategy(Randomizer randomizer, ObjectPool<WeightedGroupsRoutingStrategy> pool)

Routing\Internal\WeightedGroups\WeightedGroupsRoutingStrategyFactory.cs (1)

14private readonly ObjectPool<WeightedGroupsRoutingStrategy> _pool;

src\Shared\Pools\PoolFactory.cs (10)

39public static ObjectPool<T> CreatePool<T>(int maxCapacity = DefaultCapacity) 54public static ObjectPool<T> CreatePool<T>(IPooledObjectPolicy<T> policy, int maxCapacity = DefaultCapacity) 72public static ObjectPool<T> CreateResettingPool<T>(int maxCapacity = DefaultCapacity) 86public static ObjectPool<StringBuilder> CreateStringBuilderPool(int maxCapacity = DefaultCapacity, int maxStringBuilderCapacity = DefaultMaxStringBuilderCapacity) 114public static ObjectPool<List<T>> CreateListPool<T>(int maxCapacity = DefaultCapacity) 132public static ObjectPool<List<T>> CreateListPoolWithCapacity<T>(int listCapacity, int maxCapacity = DefaultCapacity) 152public static ObjectPool<Dictionary<TKey, TValue>> CreateDictionaryPool<TKey, TValue>(IEqualityComparer<TKey>? comparer = null, int maxCapacity = DefaultCapacity) 171public static ObjectPool<HashSet<T>> CreateHashSetPool<T>(IEqualityComparer<T>? comparer = null, int maxCapacity = DefaultCapacity) 194public static ObjectPool<CancellationTokenSource> CreateCancellationTokenSourcePool(int maxCapacity = DefaultCapacity) 204public static ObjectPool<StringBuilder> SharedStringBuilderPool { get; } = CreateStringBuilderPool();

Routing\OrderedRoutingStrategyTest.cs (1)

81internal override RequestRoutingStrategy CreateEmptyStrategy() => new OrderedGroupsRoutingStrategy(Mock.Of<Randomizer>(), Mock.Of<ObjectPool<OrderedGroupsRoutingStrategy>>());

Routing\WeightedRoutingStrategyTest.cs (1)

165internal override RequestRoutingStrategy CreateEmptyStrategy() => new WeightedGroupsRoutingStrategy(Mock.Of<Randomizer>(), Mock.Of<ObjectPool<WeightedGroupsRoutingStrategy>>());

PoolLoader.cs (10)

25private ObjectPool<PredictionEngine<TData, TPrediction>> _pool; 29private readonly ConditionalWeakTable<PredictionEngine<TData, TPrediction>, ObjectPool<PredictionEngine<TData, TPrediction>>> _rentedEngines; 38_rentedEngines = new ConditionalWeakTable<PredictionEngine<TData, TPrediction>, ObjectPool<PredictionEngine<TData, TPrediction>>>(); 54public ObjectPool<PredictionEngine<TData, TPrediction>> PredictionEnginePool { get { return Volatile.Read(ref _pool); } } 62var pool = Volatile.Read(ref _pool); 86if (_rentedEngines.TryGetValue(engine, out var origin)) 106var newPool = _poolProvider.Create(policy); 108var oldPool = Interlocked.Exchange(ref _pool, newPool); 120ObjectPool<PredictionEngine<TData, TPrediction>> pool, 141var pool = Interlocked.Exchange(ref _pool, null);

DefaultObjectPool.cs (1)

11/// Default implementation of <see cref="ObjectPool{T}"/>.

DefaultObjectPoolProvider.cs (1)

20public override ObjectPool<T> Create<T>(IPooledObjectPolicy<T> policy)

LeakTrackingObjectPool.cs (4)

12/// An <see cref="ObjectPool{T}"/> implementation that detects leaks in the use of the object pool. 25private readonly ObjectPool<T> _inner; 30/// <param name="inner">The <see cref="ObjectPool{T}"/> instance to track leaks in.</param> 31public LeakTrackingObjectPool(ObjectPool<T> inner)

LeakTrackingObjectPoolProvider.cs (2)

31public override ObjectPool<T> Create<T>(IPooledObjectPolicy<T> policy) 33var inner = _inner.Create<T>(policy);

ObjectPool.cs (2)

26/// Methods for creating <see cref="ObjectPool{T}"/> instances. 31public static ObjectPool<T> Create<T>(IPooledObjectPolicy<T>? policy = null) where T : class, new()

ObjectPoolProvider.cs (3)

7/// A provider of <see cref="ObjectPool{T}"/> instances. 15public ObjectPool<T> Create<T>() where T : class, new() 24public abstract ObjectPool<T> Create<T>(IPooledObjectPolicy<T> policy) where T : class;

ObjectPoolProviderExtensions.cs (6)

14/// Creates an <see cref="ObjectPool{T}"/> that pools <see cref="StringBuilder"/> instances. 17/// <returns>The <see cref="ObjectPool{T}"/>.</returns> 18public static ObjectPool<StringBuilder> CreateStringBuilderPool(this ObjectPoolProvider provider) 24/// Creates an <see cref="ObjectPool{T}"/> that pools <see cref="StringBuilder"/> instances. 30/// <returns>The <see cref="ObjectPool{T}"/>.</returns> 31public static ObjectPool<StringBuilder> CreateStringBuilderPool(

ObjectPoolServiceCollectionExtensions.cs (6)

16/// Extension methods for adding <see cref="ObjectPool{T}"/> to DI container. 21/// Adds an <see cref="ObjectPool{TService}"/> and lets DI return scoped instances of <typeparamref name="TService"/>. 30/// The pooled type instances are obtainable by resolving <see cref="ObjectPool{TService}"/> from the DI container. 41/// Adds an <see cref="ObjectPool{TService}"/> and lets DI return scoped instances of <typeparamref name="TService"/>. 51/// The pooled type instances are obtainable by resolving <see cref="ObjectPool{TService}"/> from the DI container. 111.AddSingleton<ObjectPool<TService>>(provider =>

DependencyInjectionExtensionsTests.cs (15)

89var pool = services.BuildServiceProvider(validateScopes: true).GetService<ObjectPool<TestDependency>>(); 104var pool = provider.GetRequiredService<ObjectPool<ITestClass>>(); 117var pool = services.BuildServiceProvider().GetService<ObjectPool<TestDependency>>(); 133var pool = provider.GetService<ObjectPool<ITestClass>>(); 147var pool = provider.GetService<ObjectPool<ITestClass>>(); 163var pool = provider.GetRequiredService<ObjectPool<ITestClass>>(); 182var pool = provider.GetRequiredService<ObjectPool<ITestClass>>(); 217Assert.Throws<InvalidOperationException>(() => provider.GetRequiredService<ObjectPool<ITestClass>>().Get());

TestResources\Pooled.cs (2)

11private readonly ObjectPool<TService> _pool; 15public Pooled(ObjectPool<TService> pool)

Latency\Internal\LatencyContext.cs (1)

17private readonly ObjectPool<LatencyContext> _poolToReturnTo;

Latency\Internal\LatencyContextPool.cs (1)

13internal ObjectPool<LatencyContext> Pool { get; set; }

Latency\Internal\ResetOnGetObjectPool.cs (1)

12private readonly ObjectPool<T> _objectPool;

Logging\JustInTimeRedactor.cs (1)

183private static readonly ObjectPool<JustInTimeRedactor> _pool = PoolFactory.CreateResettingPool<JustInTimeRedactor>();

src\Shared\LogBuffering\SerializedLogRecordFactory.cs (1)

15private static readonly ObjectPool<List<KeyValuePair<string, object?>>> _attributesPool =

src\Shared\Pools\PoolFactory.cs (10)

39public static ObjectPool<T> CreatePool<T>(int maxCapacity = DefaultCapacity) 54public static ObjectPool<T> CreatePool<T>(IPooledObjectPolicy<T> policy, int maxCapacity = DefaultCapacity) 72public static ObjectPool<T> CreateResettingPool<T>(int maxCapacity = DefaultCapacity) 86public static ObjectPool<StringBuilder> CreateStringBuilderPool(int maxCapacity = DefaultCapacity, int maxStringBuilderCapacity = DefaultMaxStringBuilderCapacity) 114public static ObjectPool<List<T>> CreateListPool<T>(int maxCapacity = DefaultCapacity) 132public static ObjectPool<List<T>> CreateListPoolWithCapacity<T>(int listCapacity, int maxCapacity = DefaultCapacity) 152public static ObjectPool<Dictionary<TKey, TValue>> CreateDictionaryPool<TKey, TValue>(IEqualityComparer<TKey>? comparer = null, int maxCapacity = DefaultCapacity) 171public static ObjectPool<HashSet<T>> CreateHashSetPool<T>(IEqualityComparer<T>? comparer = null, int maxCapacity = DefaultCapacity) 194public static ObjectPool<CancellationTokenSource> CreateCancellationTokenSourcePool(int maxCapacity = DefaultCapacity) 204public static ObjectPool<StringBuilder> SharedStringBuilderPool { get; } = CreateStringBuilderPool();

src\Shared\Pools\PoolFactory.cs (10)

39public static ObjectPool<T> CreatePool<T>(int maxCapacity = DefaultCapacity) 54public static ObjectPool<T> CreatePool<T>(IPooledObjectPolicy<T> policy, int maxCapacity = DefaultCapacity) 72public static ObjectPool<T> CreateResettingPool<T>(int maxCapacity = DefaultCapacity) 86public static ObjectPool<StringBuilder> CreateStringBuilderPool(int maxCapacity = DefaultCapacity, int maxStringBuilderCapacity = DefaultMaxStringBuilderCapacity) 114public static ObjectPool<List<T>> CreateListPool<T>(int maxCapacity = DefaultCapacity) 132public static ObjectPool<List<T>> CreateListPoolWithCapacity<T>(int listCapacity, int maxCapacity = DefaultCapacity) 152public static ObjectPool<Dictionary<TKey, TValue>> CreateDictionaryPool<TKey, TValue>(IEqualityComparer<TKey>? comparer = null, int maxCapacity = DefaultCapacity) 171public static ObjectPool<HashSet<T>> CreateHashSetPool<T>(IEqualityComparer<T>? comparer = null, int maxCapacity = DefaultCapacity) 194public static ObjectPool<CancellationTokenSource> CreateCancellationTokenSourcePool(int maxCapacity = DefaultCapacity) 204public static ObjectPool<StringBuilder> SharedStringBuilderPool { get; } = CreateStringBuilderPool();

Latency\Internal\LatencyContextTests.cs (1)

308private readonly ObjectPool<LatencyContext> _objectPool;

BufferWriterPool\BufferWriterPool.cs (2)

26public static ObjectPool<BufferWriter<T>> CreateBufferWriterPool<T>(int maxCapacity = DefaultCapacity, int maxBufferWriterCapacity = DefaultMaxBufferWriterCapacity) 37public static ObjectPool<BufferWriter<byte>> SharedBufferWriterPool { get; } = CreateBufferWriterPool<byte>();

BufferWriterPool\ReturnableBufferWriter.cs (2)

20private readonly ObjectPool<BufferWriter<T>> _pool; 26public ReturnableBufferWriter(ObjectPool<BufferWriter<T>> pool)

LogBuffering\SerializedLogRecordFactory.cs (1)

15private static readonly ObjectPool<List<KeyValuePair<string, object?>>> _attributesPool =

Pools\PoolFactory.cs (10)

39public static ObjectPool<T> CreatePool<T>(int maxCapacity = DefaultCapacity) 54public static ObjectPool<T> CreatePool<T>(IPooledObjectPolicy<T> policy, int maxCapacity = DefaultCapacity) 72public static ObjectPool<T> CreateResettingPool<T>(int maxCapacity = DefaultCapacity) 86public static ObjectPool<StringBuilder> CreateStringBuilderPool(int maxCapacity = DefaultCapacity, int maxStringBuilderCapacity = DefaultMaxStringBuilderCapacity) 114public static ObjectPool<List<T>> CreateListPool<T>(int maxCapacity = DefaultCapacity) 132public static ObjectPool<List<T>> CreateListPoolWithCapacity<T>(int listCapacity, int maxCapacity = DefaultCapacity) 152public static ObjectPool<Dictionary<TKey, TValue>> CreateDictionaryPool<TKey, TValue>(IEqualityComparer<TKey>? comparer = null, int maxCapacity = DefaultCapacity) 171public static ObjectPool<HashSet<T>> CreateHashSetPool<T>(IEqualityComparer<T>? comparer = null, int maxCapacity = DefaultCapacity) 194public static ObjectPool<CancellationTokenSource> CreateCancellationTokenSourcePool(int maxCapacity = DefaultCapacity) 204public static ObjectPool<StringBuilder> SharedStringBuilderPool { get; } = CreateStringBuilderPool();

Pools\PoolTests.cs (12)

Internals\System\Runtime\AsyncLock.cs (1)

13private static readonly ObjectPool<SemaphoreSlim> s_semaphorePool = new DefaultObjectPool<SemaphoreSlim>(new SemaphoreSlimPooledObjectPolicy(), 100);

System\ServiceModel\Channels\BinaryMessageEncoder.cs (1)

205private ObjectPool<XmlDictionaryReader> _readerPool;

System\ServiceModel\Channels\MtomMessageEncoder.cs (1)

587private ObjectPool<XmlDictionaryReader> _readerPool;

System\ServiceModel\NullCreatingPooledObjectPolicy.cs (1)

11public static ObjectPool<T> CreatePool(int maximumRetained)