我收到一个gRPC响应流,如果在500ms后没有收到消息,我想调用一个动作。我打算使用秒表类,但它更适合调试,我担心它可能不是最有效的方法。我想在现有方法中做一些事情:
while (await streamingCall.ResponseStream.MoveNext(
default(CancellationToken)))
{
}
这样:
while (await streamingCall.ResponseStream.MoveNext(
default(CancellationToken)))
{
//Message received
//Begin some sort of timer
//If no other message has been received for 500ms, execute ExampleMethod()
}
每当收到消息时,您可以将DateTime分配给变量,并在Timer中从中减去旧时间,以查看自上次消息以来经过了多长时间:
DateTime LastMsgTime = DateTime.MinValue;
Timer timer = new Timer { Interval = 50, Enabled = false };
timer.Tick += (s,e) =>
{
if((DateTime.Now- LastMsgTime).TotalMilliSeconds > 500)
{ExampleMethod(); timer.Enabled = false; }
};
while (await streamingCall.ResponseStream.MoveNext(
default(CancellationToken)))
{
LastMsgTime = DateTime.Now;
//Message received
timer.Enabled = true;
}