use lock
This commit is contained in:
@@ -42,6 +42,9 @@ public partial class Synapse
|
|||||||
|
|
||||||
private string? FireRpc(string app, string action, object? param, Dictionary<string, string>? headers = null,
|
private string? FireRpc(string app, string action, object? param, Dictionary<string, string>? headers = null,
|
||||||
int? timeout = null)
|
int? timeout = null)
|
||||||
|
{
|
||||||
|
// 检查并发情况下的线程安全问题,使用锁保证字典操作的原子性
|
||||||
|
lock (ResponseCompletionSources)
|
||||||
{
|
{
|
||||||
string paramJson;
|
string paramJson;
|
||||||
if (param is string strParam)
|
if (param is string strParam)
|
||||||
@@ -100,3 +103,4 @@ public partial class Synapse
|
|||||||
return response;
|
return response;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
}
|
||||||
Reference in New Issue
Block a user