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;