diff --git a/Dapper.Lite/Dapper.LiteTest/App.config b/Dapper.Lite/Dapper.LiteTest/App.config
index 09c8ceb..5271502 100644
--- a/Dapper.Lite/Dapper.LiteTest/App.config
+++ b/Dapper.Lite/Dapper.LiteTest/App.config
@@ -8,8 +8,8 @@
   <connectionStrings>
     <!--数据库连接-->
     <!--<add name="DefaultConnection" connectionString="Data Source=sqlite.db;Version=3;"/>-->
-    <add name="DefaultConnection" connectionString="server=localhost;database=litesql_test;user id=root;password=123456;character set=utf8mb4; min pool size=10; max pool size=50;" />
-    <!--<add name="DefaultConnection" connectionString="server=192.168.137.62;database=litesql_test;user id=root;password=abc.123;character set=gbk; min pool size=10; max pool size=50;"/>-->
+    <add name="DefaultConnection" connectionString="server=localhost;database=litesql_test;user id=root;password=123456;character set=utf8mb4;" />
+    <!--<add name="DefaultConnection" connectionString="server=192.168.137.62;database=litesql_test;user id=root;password=abc.123;character set=gbk; min pool size=10; max pool size=100;"/>-->
   </connectionStrings>
   <system.net>
     <connectionManagement>
diff --git a/Dapper.Lite/Utils/TaskSchedulerEx.cs b/Dapper.Lite/Utils/TaskSchedulerEx.cs
index 779a213..62f48ed 100644
--- a/Dapper.Lite/Utils/TaskSchedulerEx.cs
+++ b/Dapper.Lite/Utils/TaskSchedulerEx.cs
@@ -22,7 +22,6 @@ public class TaskSchedulerEx : TaskScheduler, IDisposable
         private int _auxiliaryThreadTimeOut = 20000; //辅助线程释放时间
         private int _activeThreadCount = 0;
         private System.Timers.Timer _timer;
-        private object _lockCreateTimer = new object();
         private bool _run = true;
         private Semaphore _sem = null;
         private int _semMaxCount = int.MaxValue; //可以同时授予的信号量的最大请求数
@@ -177,18 +176,17 @@ private void CreateThread()
             thread = new Thread(new ThreadStart(() =>
             {
                 Task task;
-                DateTime dt = DateTime.Now;
-                while (_run && DateTime.Now.Subtract(dt).TotalMilliseconds < _auxiliaryThreadTimeOut)
+                while (_run)
                 {
                     if (_tasks.TryDequeue(out task))
                     {
                         TryExecuteTask(task);
                         Interlocked.Decrement(ref _runCount);
-                        dt = DateTime.Now;
                     }
                     else
                     {
-                        _sem.WaitOne(_auxiliaryThreadTimeOut);
+                        bool bl = _sem.WaitOne(_auxiliaryThreadTimeOut);
+                        if (!bl) break;
                         Interlocked.Decrement(ref _semCount);
                     }
                 }