从单元测试调用时，使用 ThreadPool.QueueUserWorkItem 的异步 http 请求未发送请求

Question

我有以下静态类，它有一个发送方法，用于触发并忘记异步 http 调用。

public static class AsyncHttpRequest
{
    public static void Send(string url)
    {
        //perform an async get on the url
        try
        {
            HttpWebRequest request = (HttpWebRequest)WebRequest.Create(url);
            request.KeepAlive = false;
            ThreadPool.QueueUserWorkItem(
                o =>
                {
                    var response = request.GetResponse();
                    response.Close();
                });
        }
        catch (Exception ex)
        {
            Errors.ErrorSignal.SignalError(ex);
        }
    }
}

从 Web 应用程序项目调用相同的 URL 效果很好。但是从单元测试项目调用相同的 URL 是行不通的。它没有调用 URL。我签入了提琴手。这是为什么呢？

在这两种情况下，我都是这样打电话的 -

AsyncHttpRequest.Send("http://example.com");

Answer 1

从 Web 应用程序项目调用相同的 URL 效果很好。但是从单元测试项目调用相同的 URL 是行不通的。它没有调用 URL。我签入了提琴手。这是为什么呢？

因为单元测试框架可以快速处理所有内容。退出单元测试需要等待。

[TestMethod]
public void TestMethod()
{
    ManualResetEvent evt = new ManualResetEvent(false);

    AsyncHttpRequest.Send("someUrl", x => evt.Set());

    Assert.True(evt.Wait(100));
}

还有班级

public static class AsyncHttpRequest
{
    public static void Send(string url)
    {
        try
        {
            HttpWebRequest request = (HttpWebRequest)WebRequest.Create(url);
            request.KeepAlive = false;
            ThreadPool.QueueUserWorkItem(
                o =>
                {
                    var response = request.GetResponse();
                    response.Close();
                });
        }
        catch (Exception ex)
        {
            Errors.ErrorSignal.SignalError(ex);
        }
    }

    public static void Send(string url, Action<HttpWebResponse> callback)
    {
        try
        {
            HttpWebRequest request = (HttpWebRequest)WebRequest.Create(url);
            request.KeepAlive = false;
            ThreadPool.QueueUserWorkItem(
                o =>
                {
                    var response = request.GetResponse();
                    callback(response)
                    response.Close();

                });
        }
        catch (Exception ex)
        {
            Errors.ErrorSignal.SignalError(ex);
        }
    }
}