CZY/MES-ETL
1
0
Fork 0
Code Pull Requests Releases Activity

修复进度上下文中可能死锁的进度更新方法

Browse Source
This commit is contained in:
陈梓阳
2024-12-31 16:48:05 +08:00
parent 8037fc74de
commit 27ea80d359
1 changed files with 6 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
MesETL.App/Services/ProcessContext.cs
View File

@@ -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;