日常更新

RunTime/DBRuntime/His/Compress/CompressEnginer2.cs

@@ -345,12 +345,20 @@ namespace Cdy.Tag
                 if (mIsClosed)
                     break;
 
-                foreach (var vv in mTargetMemorys.Values)
+                System.Threading.Tasks.Parallel.ForEach(mTargetMemorys.Values, (vv) =>
                 {
+                    ThreadHelper.AssignToCPU(CPUAssignHelper.Helper.CPUArray2);
                     vv.MakeMemoryBusy();
                     vv.RequestManualToCompress();
                     vv.MakeMemoryNoBusy();
-                }
+                });
+
+                //foreach (var vv in mTargetMemorys.Values)
+                //{
+                //    vv.MakeMemoryBusy();
+                //    vv.RequestManualToCompress();
+                //    vv.MakeMemoryNoBusy();
+                //}
 
             }
         }

RunTime/DBRuntime/His/Compress/CompressMemory2.cs

@@ -141,15 +141,18 @@ namespace Cdy.Tag
         /// </summary>
         public void RequestManualToCompress()
         {
-            lock (mMemoryCach)
+            mIsRunning = true;
+            while (mMemoryCach.Count > 0)
             {
-                mIsRunning = true;
-                while (mMemoryCach.Count > 0)
+                ManualHisDataMemoryBlock vpp;
+                lock (mMemoryCach)
                 {
-                    RequestManualToCompress(mMemoryCach.Dequeue());
+                    vpp = mMemoryCach.Dequeue();
                 }
-                mIsRunning = false;
+                RequestManualToCompress(vpp);
             }
+            mIsRunning = false;
+            
         }
 
         /// <summary>
@@ -158,7 +161,8 @@ namespace Cdy.Tag
         /// <param name="data"></param>
         public void AddRequestManualToCompress(ManualHisDataMemoryBlock data)
         {
-            mMemoryCach.Enqueue(data);
+            lock (mMemoryCach)
+                mMemoryCach.Enqueue(data);
         }
 
         /// <summary>