自建线程池只用于频繁调用的重型逻辑，以及启动时可能产生争夺的场景

monk8801 · Jun 26, 2018 · 1ec2a91 · 1ec2a91
1 parent 72c4b90
commit 1ec2a91
Show file tree

Hide file tree

Showing 5 changed files with 6 additions and 10 deletions.
diff --git a/NewLife.Core/Json/JsonConfig.cs b/NewLife.Core/Json/JsonConfig.cs
@@ -48,7 +48,7 @@ public static TConfig Current
                     XTrace.WriteLine("{0}的配置文件{1}有更新，重新加载配置！", typeof(TConfig), config.ConfigFile);
 
                     // 异步更新
-                    ThreadPoolX.QueueUserWorkItem(() => config.Load(dcf));
+                    ThreadPool.QueueUserWorkItem(s => config.Load(dcf));
 
                     return config;
                 }

diff --git a/NewLife.Core/Net/SessionBase.cs b/NewLife.Core/Net/SessionBase.cs
@@ -323,7 +323,7 @@ Boolean ReceiveAsync(SocketAsyncEventArgs se, Boolean io)
                 if (io)
                     ProcessReceive(se);
                 else
-                    ThreadPoolX.QueueUserWorkItem(() => ProcessReceive(se));
+                    ThreadPoolX.QueueUserWorkItem(ProcessReceive, se);
             }
 
             return true;

diff --git a/NewLife.Core/Xml/XmlConfig.cs b/NewLife.Core/Xml/XmlConfig.cs
@@ -3,13 +3,9 @@
 using System.Reflection;
 using System.Text;
 using System.Threading;
-using System.Threading.Tasks;
 using System.Xml.Serialization;
 using NewLife.Log;
 using NewLife.Threading;
-#if NET4
-using Task = System.Threading.Tasks.TaskEx;
-#endif
 
 namespace NewLife.Xml
 {
@@ -50,7 +46,7 @@ public static TConfig Current
                     XTrace.WriteLine("{0}的配置文件{1}有更新，重新加载配置！", typeof(TConfig), config.ConfigFile);
 
                     // 异步更新
-                    ThreadPoolX.QueueUserWorkItem(() => config.Load(dcf));
+                    ThreadPool.QueueUserWorkItem(s => config.Load(dcf));
 
                     return config;
                 }

diff --git a/XCode/Cache/EntityCache.cs b/XCode/Cache/EntityCache.cs
@@ -145,7 +145,7 @@ void UpdateCacheAsync(String reason)
             // 控制只有一个线程能更新
             if (Interlocked.CompareExchange(ref _updating, 1, 0) != 0) return;
 
-            ThreadPoolX.QueueUserWorkItem(() => UpdateCache(reason));
+            ThreadPoolX.QueueUserWorkItem(UpdateCache, reason);
         }
 
         void UpdateCache(String reason)

diff --git a/XCode/Entity/IEntityModule.cs b/XCode/Entity/IEntityModule.cs
@@ -2,7 +2,7 @@
 using System.Collections;
 using System.Collections.Concurrent;
 using System.Collections.Generic;
-using NewLife.Threading;
+using System.Threading;
 
 namespace XCode
 {
@@ -59,7 +59,7 @@ public class EntityModules : IEnumerable<IEntityModule>
         public virtual void Add(IEntityModule module)
         {
             // 异步添加实体模块，避免死锁。实体类一般在静态构造函数里面添加模块，如果这里同步初始化会非常危险
-            ThreadPoolX.QueueUserWorkItem(AddAsync, module);
+            ThreadPool.QueueUserWorkItem(s => AddAsync(module));
         }
 
         /// <summary>添加实体模块</summary>