异步期间的线程安全问题，如何解决这个问题答案

【问题标题】：Thread safety issue during Async, how to get around this异步期间的线程安全问题，如何解决这个问题
【发布时间】：2014-03-30 10:38:47
【问题描述】：

我需要使用相同的 HttpClient 实例从不同的方法执行 4 个 HttpClient 请求，我认为这会导致线程安全问题。让我再解释一下。

在我正在开发的 Windows Phone 应用程序中，有一个“MainViewModel”类。这个类有一个异步方法来从网络服务器获取数据并处理响应。 Async 方法名为“LoadData”。我什至在这个类中还有 2 个异步方法（“ScheduleArrayAsync”和“CurrActivityAsync”）来帮助处理我从服务器获取的数据。

从“LoadData”方法中，我执行了 3 个 HttpClient 请求（这部分工作起来很像魅力），在处理所有这三个请求的响应时，我需要调用“ScheduleArrayAsync”方法。从那里我必须提出一个新的 HttpClient 请求（问题来了）。最后一个请求永远不会生成，即使我使用 try/catch 语句也不会生成错误代码。

让我认为这是一个线程问题的原因是，如果我将最后一个 HttpClient 请求移至“LoadData”方法，就像测试一样，它会再次起作用。

MainViewModel 类：-

public class MainViewModel : INotifyPropertyChanged
{
    public MainViewModel()
    {
        this.Employees = new ObservableCollection<Employee>();
    }

    public ObservableCollection<Employee> Employees { get; private set; }

    private JsonTextWriter jsonW;

    private string Owner;

    private RequestResponse reqPList;

    public bool IsDataLoaded
    {
        get;
        private set;
    }
    public async void LoadData()
    {
        var baseUri = new Uri("https://uri/");

        await CookieHandler.GetCookies(baseUri); // A separate request to get some cookies

        reqPList = new RequestResponse();  // The class that handle the Httpclinet

        await reqPList.GetResponse(baseUri, pList); // First request
        XmlConvertor.ConvertToXml(reqPList.Response);
        var phoneListResponse = XmlConvertor.XmlString;

        await reqPList.GetResponse(baseUri, currActiv); // Second request
        XmlConvertor.ConvertToXml(reqPList.Response);
        var currActivResponse = XmlConvertor.XmlString;

        await reqPList.GetResponse(baseUri, sched);  // Third request
        XmlConvertor.ConvertToXml(reqPList.Response);
        var schedResponse = XmlConvertor.XmlString;

        //await reqPList.GetSlotInforPOST("154215");
        var handler = new DataHandler();
        await handler.phoneListHandler(phoneListResponse);
        await handler.CurrActivitiesHandler(currActivResponse);
        await handler.ScheduleHandler(schedResponse);
        /// Do some processing included call this line 

                    #region Current activity
                    CurrActivityAsync(item, handler.currActivitiesJSON);
                    #endregion


        this.IsDataLoaded = true;
    }

    private async void CurrActivityAsync(JToken token, string jString)
    {
        // Some processing
    }

    private async void ScheduleArrayAsync(JToken token, string jString)
    {
        try
        {
            // Do some more processing and call the fourth request 
                            if (addedInfo[0].Contains("slotInfo"))
                                await reqPList.GetSlotInforPOST(addedInfo[1]);
                            else if (addedInfo[0].Contains("vacationInfo"))
                                await reqPList.GetVacationSlotInfoPOST(addedInfo[1], addedInfo[2]);

        }
        catch (Exception exp)
        {

            var d = exp.Message;
        }
    }

    public event PropertyChangedEventHandler PropertyChanged;
    private void NotifyPropertyChanged(String propertyName)
    {
        PropertyChangedEventHandler handler = PropertyChanged;
        if (null != handler)
        {
            handler(this, new PropertyChangedEventArgs(propertyName));
        }
    }
}

下面是 RequestResponse 类：-

public class RequestResponse
{
    public string Response { get; private set; }

    private HttpClient client = new HttpClient(new HttpClientHandler()
    {
        UseCookies = true,
        CookieContainer = CookieHandler.Cookiejar,
        AllowAutoRedirect = false,
        AutomaticDecompression = DecompressionMethods.Deflate | DecompressionMethods.GZip
    });

    public async Task<string> GetResponse(Uri baseuri, string uriString)
    {
        if (client.BaseAddress == null)
        {
            client.BaseAddress = baseuri; 
        }
        client.DefaultRequestHeaders.Accept.Add(new System.Net.Http.Headers.MediaTypeWithQualityHeaderValue("application/xhtml+xml"));
        var response = await client.GetAsync(baseuri + uriString);
        string webresponse = null;
        if (response.IsSuccessStatusCode)
        {
            var resp = await response.Content.ReadAsByteArrayAsync();
            var encode = Encoding.GetEncoding("iso-8859-1");
            var respString = encode.GetString(resp, 0, resp.Length - 1);
            webresponse = respString;
        }
        return Response = webresponse;
    }

    public async Task<string> GetSlotInforPOST(string timeId)
    {
        /// If the method is called from inside 'LoadData' it works.
        /// But if it is called from inside ScheduleArrayAsync, it will break at line marked with //***
        try
        {
            var baseUri = new Uri("https://uri/");
            const string slotInfo = "cgi-bin/slotInfo.pl";

            if (client.BaseAddress == null)
                client.BaseAddress = baseUri;
            client.DefaultRequestHeaders.Accept.Add(new System.Net.Http.Headers.MediaTypeWithQualityHeaderValue("application/x-www-form-urlencoded"));
            HttpContent content = new FormUrlEncodedContent(new[]
            {
                new KeyValuePair<string,string>("timeId",timeId)
            });
            var response = await client.GetAsync(baseUri + slotInfo);  // ***
            string webresponse;
            if (response.IsSuccessStatusCode)
            {
                var respo = await client.PostAsync(baseUri + slotInfo, content);
                var resp = await respo.Content.ReadAsByteArrayAsync();
                var encode = Encoding.GetEncoding("iso-8859-1");
                var respString = encode.GetString(resp, 0, resp.Length - 1);
                webresponse = respString;

            }
        }
        catch (Exception exp)
        {
            var s = exp.Message;
        }
        return Response;
    }

    public async Task<string> GetVacationSlotInfoPOST(string vacationId, string date)
    {
        // Do some HttpClient Request
    }
}

我对问题的理解正确吗？如何克服它？因为我真的需要从“ScheduleArrayAsync”而不是“LoadData”发出最后一个 HttpClient 请求

编辑只想提一下，在我努力解决问题的过程中，我在 RequestResponse 类的每个方法中都有不同的 HttpClient 实例。除了我上面提到的，当我从“LoadData”方法内部调用第四个请求时，即使它是 httpclient 的一个实例，一切都按预期工作。

【问题讨论】：

using the same HttpClient instance。你为什么这样做？你是否以某种方式依附于它？您可以创建一个新的，而不会遇到任何这些问题。
@nvoigt - 几乎是我要发布的内容:)
@DreamNet 确实如此。但在几乎所有情况下，“正确结果”都胜过“性能”:)
@nvoigt 因为 HttpClient 被设计为可重用，这样做有很多好处。重用HttpClient没有问题。但是，这些类中发生了很多奇怪的事情，可能会导致线程问题。
@DreamNet 您可能有 async void 作为签名。这将吞噬任何引发的异常。将其更改为异步任务。

标签： c# multithreading asynchronous windows-phone-8 dotnet-httpclient

【解决方案1】：

这可能是您在某些方法中作为签名的 async void。使用 async void 将防止调用函数捕获 throw 异常。从异步 void 方法抛出的异常只能由全局异常处理程序捕获。

【讨论】：

虽然我同意async void 的使用是问题的根源，但这并不是因为它吞下了异常。恰恰相反; async void 将非常大声地显示异常。
@StephenCleary 我的修订听起来更好吗？

【解决方案2】：

感谢 Darrel，我终于修好了。

为了解决这个问题，我需要更改“CurrActivityAsync”方法的签名。

来自

private async void CurrActivityAsync(JToken token, string jString)

到

private void CurrActivityAsync(JToken token, string jString)

由于此方法内部没有等待，这就是为什么它不需要在签名中使用异步。糟糕的是，我在原始帖子中没有提到这一点。

这是我唯一需要做的事情，但我什至更改了我的“ScheduleArrayAsync”的签名对异步更正确。

来自

private async void ScheduleArrayAsync(JToken token, string jString)

到

private async Task ScheduleArrayAsync(JToken token, string jString)

Darrel请您写下您的最后一条评论作为答案，以便您获得积分。

【讨论】：