【发布时间】:2020-04-28 10:58:16
【问题描述】:
我正在使用 ManualResetEventSlim 在我的应用程序中使用信号机制,如果请求/秒为 100,它会很好。随着我增加请求/秒,它会变得更糟。
例子:
100 请求/秒 -> 90% 的事务在 250 毫秒内完成,吞吐量(成功请求/秒)为 134。
150 请求/秒 -> 90% 的事务在 34067 毫秒内完成,吞吐量(成功请求/秒)为 2.2。
我使用 ConcurrentDictionary 如下:
// <key, (responseString,ManualResetEventSlim) >
private static ConcurrentDictionary<string, (string, ManualResetEventSlim)> EventsDict = new ConcurrentDictionary<string, (string, ManualResetEventSlim)>();
下面给出的过程描述了对 ManualResetEventSlim 的需求(Api 解决方案 1 和 Api 解决方案 2 完全:
Api 解决方案 1 (REST Api) 收到请求,它在 ConcurrentDictionary 中针对 key 添加一个元素(null,ManualResetEventSlim)并调用第三方服务( SOAP)使用异步/等待。第三方soap api返回确认响应,但实际响应待定。得到确认响应后,进入ManualResetEventSlim.wait
一旦第三方处理了请求,它就会使用公开的方法调用 Api 解决方案 2 (SOAP) 并发送实际响应。 Api 解决方案 2 通过发出 http 请求向 Api 解决方案 1 (REST Api) 发送响应,然后将数据插入数据库以进行审计日志。
Api Solution 1将从响应字符串中获取key并更新ConcurrentDictionary中的响应字符串并设置信号。
Api 解决方案 1 在向客户端返回响应之前释放 ManualResetEventSlim 对象。
【问题讨论】:
-
只要 Solution2 工作,您就会阻塞 Solution1 的线程。您是否考虑过使用基于任务的异步(“async/await”)?
-
是的,它是一个肥皂服务,我使用 async/await 但它总是返回两个响应。解决方案 2 是一个第三方服务,它会立即为每个请求返回确认响应,并且它要求在单独的公开方法上发送实际响应。我需要阻止请求,直到我得到实际响应
-
"当等待时间预计非常短,并且事件不跨越进程边界时,您可以使用ManualResetEventSlim获得比ManualResetEvent更好的性能b>" - docs.microsoft.com/en-us/dotnet/api/…
-
您能否详细说明解决方案 2 发出的信号是如何工作的?当可以获取结果时如何得到通知?那是回调吗?一个事件?还有什么?
-
@PeterCsala 我已经在使用 ManualResetEventSlim
标签: c# multithreading asp.net-core signals event-wait-handle