Kenji-NX/src/Ryujinx.Common/Pools/ObjectPool.cs

using System;
using System.Collections.Concurrent;
using System.Threading;

namespace Ryujinx.Common
{
    public class ObjectPool<T>(Func<T> factory, int size = -1)
        where T : class
    {
        private int _size = size;
        private readonly ConcurrentBag<T> _items = new();

        public T Allocate()
        {
            bool success = _items.TryTake(out T instance);

            if (!success)
            {
                instance =  factory();
            }

            return instance;
        }

        public void Release(T obj)
        {
            if (_size < 0 || _items.Count < _size)
            {
                _items.Add(obj);
            }
        }
        
        public void Clear() => _items.Clear();
    }
}