基于任务的超时,激活速度慢于预期



我有一个HttpMessage,它在某个时候需要一个结果。我希望用户能够等待一个任务,该任务在设置响应后或超时后返回乙醚。当运行我的单元测试时,它可以工作,但前提是我设置的超时时间比响应的延迟设置早得多。

为什么会发生这种情况,我能做些什么来缩短时间吗。

*请注意,下面的单元测试是有效的,但如果将延迟设置为500ms,则失败

HttpMessage代码:

public async Task<bool> ContinueWhenResponseRecieved(int Timeout)
        {
            NotifyTaskCompletionSource = new TaskCompletionSource<bool>();
            bool result = true;
            //If we have already recieved a response return true;
            if (this._response != null)
            {
                return result;
            }
            //If Timeout is not 0 then start a task that after the timeout period will set the completion source to true no matter what
            if (Timeout != 0) 
            {
                TaskEx.Run(async () =>
                {
                    await TaskEx.Delay(Timeout);
                    result = false;
                    try
                    {
                        NotifyTaskCompletionSource.SetResult(true);
                    }
                    catch (Exception ex) { } //ignore race condition issues
                });
            }
            await NotifyTaskCompletionSource.Task;
            return result;
        }
        public override IHttpMessage setResponse(HttpResponse _response)
        {
            if (NotifyTaskCompletionSource != null)
            {
                try
                {
                    NotifyTaskCompletionSource.SetResult(true);
                }catch(Exception ex){} //Ignore race condtion issues
            }
            return base.setResponse(_response);
        }

单元测试:

  [TestMethod]
    public async Task TestNotifiableTimeOuts()
    {
        var msg = new NotifiableHttpMessage();
        TaskEx.Run(() =>
        {
            TaskEx.Delay(1000).Wait();
            msg.setResponse(new Messages.HttpResponse());
        });
        var result= await msg.ContinueWhenResponseRecieved(50);
        Assert.IsFalse(result);
    }

信用服务

问题是单元测试不是异步的,并且导致了问题。一个完全清除的异步测试完成了任务。最终结果单元测试:

[TestMethod]
    public async Task TestNotifiableTimeOuts()
    {
        var msg = new NotifiableHttpMessage();
        TaskEx.Run(async () =>
        {
            await TaskEx.Delay(200);
            msg.setResponse(new Messages.HttpResponse());
        });
        var result= await msg.ContinueWhenResponseRecieved(50);
        Assert.IsFalse(result);
    }

最新更新