tk/FreeSql
1
0
Fork 0
mirror of https://github.com/nsnail/FreeSql.git synced 2025-11-04 09:15:27 +08:00
Code Issues Packages Projects Releases Wiki Activity

优化 连接池对象预热效率，开启每10个线程进行预热；

Browse Source
This commit is contained in:
28810
2019-04-10 13:50:36 +08:00
parent 40571ed0e5
commit c3c7539150
6 changed files with 42 additions and 51 deletions
Download Patch File Download Diff File Expand all files Collapse all files

38
FreeSql/FreeUtil.cs
View File

@@ -1,6 +1,10 @@
using System;
using SafeObjectPool;
using System;
using System.Collections.Concurrent;
using System.Data.Common;
using System.Diagnostics;
using System.Threading;
using System.Threading.Tasks;
public static class FreeUtil {
@@ -27,4 +31,36 @@ public static class FreeUtil {
var guid = $"{uninxtime.ToString("x8").PadLeft(8, '0')}{__staticMachine.ToString("x8").PadLeft(8, '0').Substring(2, 6)}{__staticPid.ToString("x8").PadLeft(8, '0').Substring(6, 2)}{increment.ToString("x8").PadLeft(8, '0')}{rand.ToString("x8").PadLeft(8, '0')}";
return Guid.Parse(guid);
}
internal static void PrevReheatConnectionPool(ObjectPool<DbConnection> pool) {
var initTestOk = true;
var initStartTime = DateTime.Now;
var initConns = new ConcurrentBag<Object<DbConnection>>();
try {
var conn = pool.Get();
initConns.Add(conn);
pool.Policy.OnCheckAvailable(conn);
} catch {
initTestOk = false; //预热一次失败，后面将不进行
}
for (var a = 1; initTestOk && a < pool.Policy.PoolSize; a += 10) {
if (initStartTime.Subtract(DateTime.Now).TotalSeconds > 3) break; //预热耗时超过3秒，退出
var b = Math.Min(pool.Policy.PoolSize - a, 10); //每10个预热
var initTasks = new Task[b];
for (var c = 0; c < b; c++) {
initTasks[c] = Task.Run(() => {
try {
var conn = pool.Get();
initConns.Add(conn);
pool.Policy.OnCheckAvailable(conn);
} catch {
initTestOk = false; //有失败，下一组退出预热
}
});
}
Task.WaitAll(initTasks);
}
while (initConns.TryTake(out var conn)) pool.Return(conn);
}
}

11
FreeSql/MySql/MySqlAdo/MySqlConnectionPool.cs
View File

@@ -69,16 +69,7 @@ namespace FreeSql.MySql {
_connectionString = Regex.Replace(_connectionString, pattern, "", RegexOptions.IgnoreCase);
}
var initConns = new List<Object<DbConnection>>();
for (var a = 0; a < PoolSize; a++)
try {
var conn = _pool.Get();
initConns.Add(conn);
conn.Value.Ping(true);
} catch {
break; //预热失败一次就退出
}
foreach (var conn in initConns) _pool.Return(conn);
FreeUtil.PrevReheatConnectionPool(_pool);
}
}

11
FreeSql/Oracle/OracleAdo/OracleConnectionPool.cs
View File

@@ -83,16 +83,7 @@ namespace FreeSql.Oracle {
_connectionString = Regex.Replace(_connectionString, pattern, "", RegexOptions.IgnoreCase);
}
var initConns = new List<Object<DbConnection>>();
for (var a = 0; a < PoolSize; a++)
try {
var conn = _pool.Get();
initConns.Add(conn);
conn.Value.Ping(true);
} catch {
break; //预热失败一次就退出
}
foreach (var conn in initConns) _pool.Return(conn);
FreeUtil.PrevReheatConnectionPool(_pool);
}
}

11
FreeSql/PostgreSQL/PostgreSQLAdo/PostgreSQLConnectionPool.cs
View File

@@ -78,16 +78,7 @@ namespace FreeSql.PostgreSQL {
_connectionString = Regex.Replace(_connectionString, pattern, "", RegexOptions.IgnoreCase);
}
var initConns = new List<Object<DbConnection>>();
for (var a = 0; a < PoolSize; a++)
try {
var conn = _pool.Get();
initConns.Add(conn);
conn.Value.Ping(true);
} catch {
break; //预热失败一次就退出
}
foreach (var conn in initConns) _pool.Return(conn);
FreeUtil.PrevReheatConnectionPool(_pool);
}
}

11
FreeSql/SqlServer/SqlServerAdo/SqlServerConnectionPool.cs
View File

@@ -73,16 +73,7 @@ namespace FreeSql.SqlServer {
_connectionString = Regex.Replace(_connectionString, pattern, "", RegexOptions.IgnoreCase);
}
var initConns = new List<Object<DbConnection>>();
for (var a = 0; a < PoolSize; a++)
try {
var conn = _pool.Get();
initConns.Add(conn);
conn.Value.Ping(true);
} catch {
break; //预热失败一次就退出
}
foreach (var conn in initConns) _pool.Return(conn);
FreeUtil.PrevReheatConnectionPool(_pool);
}
}

11
FreeSql/Sqlite/SqliteAdo/SqliteConnectionPool.cs
View File

@@ -80,16 +80,7 @@ namespace FreeSql.Sqlite {
Attaches = (idx == -1 ? att[1] : att[1].Substring(0, idx)).Split(',');
}
var initConns = new List<Object<DbConnection>>();
for (var a = 0; a < PoolSize; a++)
try {
var conn = _pool.Get();
initConns.Add(conn);
conn.Value.Ping(true);
} catch {
break; //预热失败一次就退出
}
foreach (var conn in initConns) _pool.Return(conn);
FreeUtil.PrevReheatConnectionPool(_pool);
}
}