From 27ea80d35987676d79f25059e967b093b48c9524 Mon Sep 17 00:00:00 2001
From: "2817212736@qq.com" <2817212736@qq.com>
Date: Tue, 31 Dec 2024 16:48:05 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E8=BF=9B=E5=BA=A6=E4=B8=8A?=
 =?UTF-8?q?=E4=B8=8B=E6=96=87=E4=B8=AD=E5=8F=AF=E8=83=BD=E6=AD=BB=E9=94=81?=
 =?UTF-8?q?=E7=9A=84=E8=BF=9B=E5=BA=A6=E6=9B=B4=E6=96=B0=E6=96=B9=E6=B3=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 MesETL.App/Services/ProcessContext.cs | 13 ++++++-------
 1 file changed, 6 insertions(+), 7 deletions(-)

diff --git a/MesETL.App/Services/ProcessContext.cs b/MesETL.App/Services/ProcessContext.cs
index 583dbe4..d9c26be 100644
--- a/MesETL.App/Services/ProcessContext.cs
+++ b/MesETL.App/Services/ProcessContext.cs
@@ -59,17 +59,16 @@ public class ProcessContext
 
     public void AddTableInput(string table, int count)
     {
-        if (!_tableProgress.TryAdd(table, (input: count, output: 0)))
+        _tableProgress.AddOrUpdate(table, (input: count, output: 0), (k, tuple) =>
         {
-            var tuple = _tableProgress[table];
-            tuple.input += count;
-            _tableProgress[table] = tuple;
-        }
+            tuple.output += count;
+            return tuple;
+        });
     }
-    
+
     public void AddTableOutput(string table, int count)
     {
-        _tableProgress.AddOrUpdate(table, (input:0, output:count), (k, tuple) =>
+        _tableProgress.AddOrUpdate(table, (input: 0, output: count), (k, tuple) =>
         {
             tuple.output += count;
             return tuple;