From 858dadcdd1caadb5fa8cc13a02eb227098f39c3c Mon Sep 17 00:00:00 2001
From: Bond_009 <bond.009@outlook.com>
Date: Fri, 14 Apr 2023 13:43:56 +0200
Subject: POC sql connection pool

---
 Emby.Server.Implementations/Data/ConnectionPool.cs | 68 ++++++++++++++++++++++
 1 file changed, 68 insertions(+)
 create mode 100644 Emby.Server.Implementations/Data/ConnectionPool.cs

(limited to 'Emby.Server.Implementations/Data/ConnectionPool.cs')

diff --git a/Emby.Server.Implementations/Data/ConnectionPool.cs b/Emby.Server.Implementations/Data/ConnectionPool.cs
new file mode 100644
index 000000000..86a125ba5
--- /dev/null
+++ b/Emby.Server.Implementations/Data/ConnectionPool.cs
@@ -0,0 +1,68 @@
+#pragma warning disable CS1591
+
+using System;
+using System.Collections.Concurrent;
+using System.Threading;
+using SQLitePCL.pretty;
+
+namespace Emby.Server.Implementations.Data;
+
+public sealed class ConnectionPool : IDisposable
+{
+    private readonly int _count;
+    private readonly SemaphoreSlim _lock;
+    private readonly ConcurrentQueue<SQLiteDatabaseConnection> _connections = new ConcurrentQueue<SQLiteDatabaseConnection>();
+    private bool _disposed;
+
+    public ConnectionPool(int count, Func<SQLiteDatabaseConnection> factory)
+    {
+        _count = count;
+        _lock = new SemaphoreSlim(count, count);
+        for (int i = 0; i < count; i++)
+        {
+            _connections.Enqueue(factory.Invoke());
+        }
+    }
+
+    public ManagedConnection GetConnection()
+    {
+        _lock.Wait();
+        if (!_connections.TryDequeue(out var connection))
+        {
+            _lock.Release();
+            throw new InvalidOperationException();
+        }
+
+        return new ManagedConnection(connection, this);
+    }
+
+    public void Return(SQLiteDatabaseConnection connection)
+    {
+        _connections.Enqueue(connection);
+        _lock.Release();
+    }
+
+    public void Dispose()
+    {
+        if (_disposed)
+        {
+            return;
+        }
+
+        for (int i = 0; i < _count; i++)
+        {
+            _lock.Wait();
+            if (!_connections.TryDequeue(out var connection))
+            {
+                _lock.Release();
+                throw new InvalidOperationException();
+            }
+
+            connection.Dispose();
+        }
+
+        _lock.Dispose();
+
+        _disposed = true;
+    }
+}
-- 
cgit v1.2.3