猿问

如何取消 Socket.ReceiveFromAsync()?

我正在使用 dotnet core 2.2 并具有以下 UDP 侦听器:


var socket = new Socket(ep.AddressFamily, SocketType.Dgram, ProtocolType.Udp);

while (true)

{

    var result = await socket.ReceiveFromAsync(...);

}

现在在某些情况下,我想中断ReceiveFromAsync()通话。但似乎与 TCP 案例(即ReceiveAsync())不同,没有ReceiveFromAsync()接受过载CancellationToken。


一种选择是与Task.Delay(-1, ct);一起使用Task.WhenAny()/Task.WhenAll()。但我认为这个解决方案会导致内存泄漏,对吧?我的意思是.ReceiveFromAsync()如果被打断,呼叫仍然“存在”,只是在后台。也可能导致逻辑中断,因为这样的调用会读取一个 UDP 数据包并在之后丢弃它?还是我的推理不正确?


另一个想法是让后台工作人员从 UDP 套接字读取数据并对每个数据包进行排队。并且这里不会发生中断。然后我会从队列中读取并中断这个呼叫。这会奏效,但肯定需要一些努力。我看到的问题是:线程安全和性能。


有没有更清洁/更简单的方法来处理这种情况?


拉丁的传说
浏览 87回答 1
1回答

墨色风雨

对于“不可取消”的 I/O 请求,Windows 中的标准模式是关闭底层句柄——在本例中为套接字。这通常会导致任何异步(或同步)操作以错误代码完成。在您的情况下-“暂停” UDP 接收器-我认为这种方法特别有意义。无论如何,UDP 套接字并不代表打开的连接,因此关闭套接字是最好的解决方案。关于Task.Delaywith Task.WhenAny,您的担忧是完全正确的。Task.Delay+Task.WhenAny方法只取消操作的等待,而不是操作本身。具体来说,它不会取消 UDP 接收,并且未取消的 UDP 接收操作可能会获得一个随后会“丢失”的数据包,因为您的应用程序会忽略它。
随时随地看视频慕课网APP
我要回答