引入惰性消费者，让缓存更新的查询在异步任务中串行执行，避免并行查询卡死SQLite数据库。StarServer更新后，完成任务的曲线不再有明显凸起的波峰。

Author: nnhy

XCode/Cache/CacheBase.cs

@@ -15,6 +15,9 @@ namespace XCode.Cache;
 
     /// <summary>表名</summary>
     public String TableName { get; set; } = null!;
+
+    /// <summary>当前实体类专用的惰性消费者。让缓存更新异步串行执行，避免并行阻塞数据库</summary>
+    protected LazyConsumer Consumer { get; } = new();
     #endregion
 
     /// <summary>调用委托方法前设置连接名和表名，调用后还原</summary>

XCode/Cache/EntityCache.cs

@@ -159,7 +159,7 @@ void UpdateCacheAsync(String reason)
 
         reason = $"异步更新缓存，{reason}";
         WriteLog(reason);
-        Task.Run(() => UpdateCache(reason, true));
+        Consumer.Run(() => UpdateCache(reason, true));
     }
 
     void UpdateCache(String reason, Boolean isAsync = false)

XCode/Cache/LazyConsumer.cs

@@ -0,0 +1,53 @@
+using System.Collections.Concurrent;
+
+namespace XCode.Cache;
+
+/// <summary>
+/// 惰性串行消费者：仅在有任务时启动后台 Task，任务处理完自动退出，空闲时不占线程。
+/// 所有任务严格按入队顺序串行执行。
+/// </summary>
+public class LazyConsumer
+{
+    private readonly ConcurrentQueue<Action> _queue = new();
+    private volatile Int32 _processing = 0; // 0: 空闲, 1: 正在处理
+
+    /// <summary>
+    /// 提交一个任务，由内部串行执行
+    /// </summary>
+    public void Run(Action item)
+    {
+        _queue.Enqueue(item);
+
+        // 尝试启动处理任务（仅当当前无活跃任务）
+        if (Interlocked.CompareExchange(ref _processing, 1, 0) == 0)
+        {
+            // 成功抢到启动权
+            _ = Task.Run(ProcessQueue);
+        }
+    }
+
+    private void ProcessQueue()
+    {
+        try
+        {
+            // 一次性处理当前所有任务（drain）
+            while (_queue.TryDequeue(out var action))
+            {
+                try
+                {
+                    action();
+                }
+                catch
+                {
+                    // 可选：记录日志。此处不抛出，避免中断队列
+                }
+            }
+        }
+        catch { }
+        finally
+        {
+            // 标记为空闲
+            _processing = 0;
+        }
+    }
+}

XCode/Cache/SingleEntityCache.cs

@@ -296,7 +296,7 @@ public void ShowStatics()
         {
             // 频繁更新下，采用异步更新缓存，以提升吞吐。非频繁访问时（2倍超时），同步更新
             if (sec < Expire)
-                Task.Run(() => UpdateData(ci, key));
+                Consumer.Run(() => UpdateData(ci, key));
             else
                 UpdateData(ci, key);
         }

XCode/Entity/EntityQueue.cs

@@ -8,7 +8,7 @@
 namespace XCode;
 
 /// <summary>实体队列。支持凑批更新数据，包括Insert/Update/Delete/Upsert</summary>
-public class EntityQueue : DisposeBase
+public class EntityQueue(IEntitySession session) : DisposeBase
 {
     #region 属性
     /// <summary>需要近实时保存的实体队列</summary>
@@ -21,7 +21,7 @@ public class EntityQueue : DisposeBase
     public Boolean Debug { get; set; }
 
     /// <summary>数据会话，分表分库时使用</summary>
-    public IEntitySession Session { get; }
+    public IEntitySession Session { get; } = session;
 
     /// <summary>是否仅插入。默认false</summary>
     public Boolean InsertOnly { get; set; }
@@ -48,12 +48,9 @@ public class EntityQueue : DisposeBase
 
     private TimerX? _Timer;
     private String? _lastTraceId;
-    #endregion
 
+    #endregion
     #region 构造
-    /// <summary>实例化实体队列</summary>
-    public EntityQueue(IEntitySession session) => Session = session;
-
     /// <summary>销毁时，持久化队列</summary>
     /// <param name="disposing"></param>
     protected override void Dispose(Boolean disposing)