减轻线程池负担

monk8801 · Jun 25, 2018 · 5b68b18 · 5b68b18
1 parent 8a02c2d
commit 5b68b18
Show file tree

Hide file tree

Showing 4 changed files with 6 additions and 3 deletions.
diff --git a/NewLife.Core/Agent/AgentServiceBase.cs b/NewLife.Core/Agent/AgentServiceBase.cs
@@ -23,6 +23,8 @@ public abstract class AgentServiceBase<TService> : AgentServiceBase, IAgentServi
         #region 构造
         static AgentServiceBase()
         {
+            XTrace.UseConsole();
+
             if (_Instance == null) _Instance = new TService();
         }
 
@@ -126,7 +128,6 @@ public static void ServiceMain()
                 Console.Title = service.DisplayName;
 
                 #region 命令行
-                XTrace.UseConsole();
                 service.Log = XTrace.Log;
 
                 // 输出状态

diff --git a/NewLife.Core/Log/PerfCounter.cs b/NewLife.Core/Log/PerfCounter.cs
@@ -53,7 +53,7 @@ public void Increment(Int64 value, Int64 usCost)
             {
                 lock (this)
                 {
-                    if (_Timer == null) _Timer = new TimerX(DoWork, null, Interval, Interval) { Async = true };
+                    if (_Timer == null) _Timer = new TimerX(DoWork, null, Interval, Interval);
                 }
             }
         }

diff --git a/XCode/Entity/Entity.cs b/XCode/Entity/Entity.cs
@@ -884,7 +884,8 @@ public static Int64 FindCount(Expression where, String order = null, String sele
         ///// <returns>总行数</returns>
         //public static Int32 FindCount(String sql)
         //{
-        //    if (!sql.ToLower().Contains("select"))        //        return FindCount(sql, null, null, 0, 0);
+        //    if (!sql.ToLower().Contains("select"))
+        //        return FindCount(sql, null, null, 0, 0);
 
         //    var session = Meta.Session;
 

diff --git a/XCode/Entity/EntityQueue.cs b/XCode/Entity/EntityQueue.cs
@@ -51,6 +51,7 @@ public EntityQueue(IEntitySession session)
         {
             Session = session;
             _Timer = new TimerX(Work, null, Period, Period, "EQ") { Async = true };
+            _Timer.CanExecute = () => DelayEntities.Any() || Entities.Any();
         }
         #endregion
-Original file line number
+Diff line change
@@ Expand Up / @@ -53,7 +53,7 @@ public void Increment(Int64 value, Int64 usCost) @@
                 {
                     lock (this)
                     {
-                        if (_Timer == null) _Timer = new TimerX(DoWork, null, Interval, Interval) { Async = true };
+                        if (_Timer == null) _Timer = new TimerX(DoWork, null, Interval, Interval);
                     }
                 }
             }
@@ Expand Down @@