我正在实现我的应用程序的网络层,即使用异步 JSON-RPC 协议。
为了与服务器通信,我想做一个方法来发送正确的请求,等到服务器发送响应,然后返回。一切都使用 async/await 关键字。
这是简化的示例代码:
字符串响应;
Task<string> SendRequest(string methodName, string methodParams)
{
string request = generateRequest(methodName, methodParams);
await Send(request); // this will send using DataWriter, and StreamSocket
// block Task until response arrives
return response;
}
async void ReceiveLoop()
{
while (true)
{
uint numStrBytes = await _reader.LoadAsync(BufferSize);
string msg = _reader.ReadString(numStrBytes);
response = msg;
// unblock previously blocked SendRequest
}
}
}
async void main()
{
RecieveLoop();
}
async void SendButtonPressed()
{
string response = await SendRequest("Test method", "Test params");
Debug.WriteLine("Response = " + response);
}
这种模式的主要问题是这种阻塞动作。此操作应阻止当前任务,并允许处理超时。我尝试使用 ManualResetEvent 和 WaitOne(int) 来处理这个问题,但它冻结了整个线程,并且因为我只使用 async/await,它冻结了整个应用程序(对我来说更准确的是 UI 线程)。
对我来说看起来很老套的解决方案是我可以将 Task.Delay 与 CancellationTokens 一起使用。
它看起来像这样:
...
CancellationTokenSource cts;
int timeout = 10000;
Task<string> SendRequest(string methodName, string methodParams)
{
... (prepare request, and send)
cts = new CancellationTokenSource();
try
{
await Task.Delay(timeout, cts.Token);
} catch(TaskCanceledException)
{
}
// do rest
}
async void ReceiveLoop()
{
// init recieve loop, and recieve message
cts.Cancel();
}
该解决方案的问题(除了看起来像黑客之外)是性能 - 每个请求都会抛出一个异常,需要处理(在这种情况下跳过)。这个很慢,很痛:)
我怎样才能以更优雅的方式做到这一点?是否有任何其他选项可以阻止任务?