mirror of https://github.com/jellyfin/jellyfin.git
Change number of read connections based on # of threads and add comments
This commit is contained in:
parent
8dba3a44fd
commit
13152bf09d
|
@ -1,16 +1,22 @@
|
||||||
#pragma warning disable CS1591
|
|
||||||
|
|
||||||
using System;
|
using System;
|
||||||
using System.Collections.Concurrent;
|
using System.Collections.Concurrent;
|
||||||
using SQLitePCL.pretty;
|
using SQLitePCL.pretty;
|
||||||
|
|
||||||
namespace Emby.Server.Implementations.Data;
|
namespace Emby.Server.Implementations.Data;
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// A pool of SQLite Database connections.
|
||||||
|
/// </summary>
|
||||||
public sealed class ConnectionPool : IDisposable
|
public sealed class ConnectionPool : IDisposable
|
||||||
{
|
{
|
||||||
private readonly BlockingCollection<SQLiteDatabaseConnection> _connections = new();
|
private readonly BlockingCollection<SQLiteDatabaseConnection> _connections = new();
|
||||||
private bool _disposed;
|
private bool _disposed;
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// Initializes a new instance of the <see cref="ConnectionPool" /> class.
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="count">The number of database connection to create.</param>
|
||||||
|
/// <param name="factory">Factory function to create the database connections.</param>
|
||||||
public ConnectionPool(int count, Func<SQLiteDatabaseConnection> factory)
|
public ConnectionPool(int count, Func<SQLiteDatabaseConnection> factory)
|
||||||
{
|
{
|
||||||
for (int i = 0; i < count; i++)
|
for (int i = 0; i < count; i++)
|
||||||
|
@ -19,6 +25,10 @@ public sealed class ConnectionPool : IDisposable
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// Gets a database connection from the pool if one is available, otherwise blocks.
|
||||||
|
/// </summary>
|
||||||
|
/// <returns>A database connection.</returns>
|
||||||
public ManagedConnection GetConnection()
|
public ManagedConnection GetConnection()
|
||||||
{
|
{
|
||||||
if (_disposed)
|
if (_disposed)
|
||||||
|
@ -34,6 +44,10 @@ public sealed class ConnectionPool : IDisposable
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/// <summary>
|
||||||
|
/// Return a database connection to the pool.
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="connection">The database connection to return.</param>
|
||||||
public void Return(SQLiteDatabaseConnection connection)
|
public void Return(SQLiteDatabaseConnection connection)
|
||||||
{
|
{
|
||||||
if (_disposed)
|
if (_disposed)
|
||||||
|
@ -45,6 +59,7 @@ public sealed class ConnectionPool : IDisposable
|
||||||
_connections.Add(connection);
|
_connections.Add(connection);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/// <inheritdoc />
|
||||||
public void Dispose()
|
public void Dispose()
|
||||||
{
|
{
|
||||||
if (_disposed)
|
if (_disposed)
|
||||||
|
|
|
@ -336,7 +336,7 @@ namespace Emby.Server.Implementations.Data
|
||||||
_jsonOptions = JsonDefaults.Options;
|
_jsonOptions = JsonDefaults.Options;
|
||||||
|
|
||||||
DbFilePath = Path.Combine(_config.ApplicationPaths.DataPath, "library.db");
|
DbFilePath = Path.Combine(_config.ApplicationPaths.DataPath, "library.db");
|
||||||
ReadConnectionsCount = 5;
|
ReadConnectionsCount = Environment.ProcessorCount * 2;
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <inheritdoc />
|
/// <inheritdoc />
|
||||||
|
|
Loading…
Reference in New Issue