异步任务不返回主线程

Question

我认为这与我非常糟糕的异步编程有关。

来了。我正在使用异步方法获取 mailchimp 订阅者，但结果只是挂起并且永远不会返回到主线程。

异步方法

public async Task<List<Subscriber>> GetMailChimpSubscribers()
{
    TaskCompletionSource<List<Subscriber>> result = new TaskCompletionSource<List<Subscriber>>();
    await Task.Run(async () =>
    {
        var subscribers = new List<Subscriber>();
        var listId = "";
        var members = await _manager.Members.GetAllAsync(listId);
        foreach (var item in members)
        {
            var sub = new Subscriber();
            sub.Email = item.EmailAddress;
            subscribers.Add(sub);
        }
        result.SetResult(subscribers);
    });
    return result.Task.Result;
}

这在 result.SetResult(subscribers) 语句之后完全挂起。

这是从

调用的

public static List<Subscriber> GetSubscribers()
{
    MailchimpHelper helper = new MailchimpHelper();
    var subscribers= helper.GetMailChimpSubscribers();

    return subscribers.Result;
}

这里到底出了什么问题？设置错了吗？

PS：mailchimp 或 api 没有问题，它在控制台中运行良好。这对于异步编程来说纯粹是一件坏事

更新：

如果有人遇到这种情况。该博客帮助清除了很多

https://blog.stephencleary.com/2012/07/dont-block-on-async-code.html

以下答案和博客中的工作解决方案。

public async Task<List<Subscriber>> GetMailChimpSubscribers()
   {
    var subscribers = new List<Subscriber>();
    var listId = "";
    var members = 
     await   _manager.Members.GetAllAsync(listId).**ConfigureAwait(false)**;

    foreach (var item in members)
    {
        var sub = new Subscriber();
        sub.Email = item.EmailAddress;
        subscribers.Add(sub);
    }

    return subscribers;


} 

public static List<Subscriber> GetSubscribers()
{
    MailchimpHelper helper = new MailchimpHelper();
    var subscribers= helper.GetMailChimpSubscribers();
    subscribers.Wait();

    return subscribers.Result;
}

Answer 1

这里有很多错误：

• 实际问题是blocking on asynchronous code, which causes a deadlock。
• TaskCompletionSource<T> 的用法也令人困惑且不必要。
• 似乎也不需要Task.Run。

删除所有不好的部分给我们留下：

public async Task<List<Subscriber>> GetMailChimpSubscribersAsync()
{
  var subscribers = new List<Subscriber>();
  var listId = "";
  var members = await _manager.Members.GetAllAsync(listId);
  foreach (var item in members)
  {
    var sub = new Subscriber();
    sub.Email = item.EmailAddress;
    subscribers.Add(sub);
  }
  return subscribers;
}

public static async Task<List<Subscriber>> GetSubscribersAsync()
{
  MailchimpHelper helper = new MailchimpHelper();
  return await helper.GetMailChimpSubscribersAsync();
}

Answer 2

不要在具有同步上下文的环境中使用 .Result - 它会创建循环等待。

一般情况下，如果可能，请尝试“一直使用”async - 即，如果您打算使用 async/await，您应该只使用async/await.

请参阅 Stephen Cleary 的 Don't Block on Async Code 了解更多详情。

Answer 3

问题的第一部分是，出于某种奇怪的原因，您将任务包装在另一个任务中。将您的方法更改为：

public async Task<List<Subscriber>> GetMailChimpSubscribers()
{
    var subscribers = new List<Subscriber>();
    var listId = "";
    var members = await _manager.Members.GetAllAsync(listId);
    foreach (var item in members) //this foreach could be a simpler LinQ statement
    {
        var sub = new Subscriber();
        sub.Email = item.EmailAddress;
        subscribers.Add(sub);
    }

    return subscribers;
}

您还应该使用 await 调用此方法，但如果这不可能，则将您的方法更改为：

public static List<Subscriber> GetSubscribers()
{
    MailchimpHelper helper = new MailchimpHelper();
    var subscribers = helper.GetMailChimpSubscribers();
    subscribers.Wait();
    return subscribers.Result;
}