'System.Threading.Tasks.Task'不包含'Result'的定义

Question

我有一个facebook查询,如下所示

var client = new FacebookClient(accessToken);
var dynamic = client.Get(connection, new { fields = "name,from,story,message,picture,comments", limit = count});
foreach (var dynPost in results.data)
{
     posts.Add(ConvertToPost(dynPost));
}

我试图通过向Facebook并行提出大量较小的请求来加快速度.

using (profilingService.Start("Facebook calls"))
{ 
    var pullSize = 25;
    var numberOfCalls = (int)Math.Ceiling(count / (double)pullSize);

    var taskQueue = new Queue<Task>();
    for (int i = 0; i < numberOfCalls; i++)
    {
        taskQueue.Enqueue(Task.Factory.StartNew(() =>
        {
            var offset = i * pullSize;
            var client = new FacebookClient(accessToken);
            return client.Get(connection, new { fields = "name,from,story,message,picture,comments", limit = 25, offset = offset });
        }));
    }

    Task.Factory.ContinueWhenAll(
        taskQueue,
        tasks =>
        {
            //t.Result here is giving me the error
            var results = tasks.Select(t => t.Result);
            foreach (var result in results)
            {
                foreach (var dynPost in result.data)
                {
                    posts.Add(ConvertToPost(dynPost.data));
                }
            }
        });
}

首先,我收到了错误 var results = tasks.Select(t => t.Result);

错误361'System.Threading.Tasks.Task'不包含'Result'的定义,并且没有可以找到接受类型'System.Threading.Tasks.Task'的第一个参数的扩展方法'Result'(你错过了吗？使用指令或程序集引用？)

t是类型 Task<AntecedentResult>

这导致我进入这个页面,但仍然无法解决它.这个异步任务方法有什么问题？

另外,我对这种并行编码没有太多经验,我做错了什么或应该以不同的方式做什么？

Answer 1

问题是Queue<Task>.Task单独没有Result财产.但是,Task<Foo>具有Result类型的属性Foo.(我不知道会有什么client.Get(...)回报,让我们Foo现在就叫它:

var taskQueue = new Queue<Task<Foo>>();

该ContinueWhenAll方法不支持Queue<>,仅支持Task[]和Task<>[],因此您需要先将其转换为数组.

Task.Factory.ContinueWhenAll(
    taskQueue.ToArray(),
    tasks =>
    {
        var results = tasks.Select(t => t.Result);
        foreach (var result in results)
        {
            ...
        }
    });
}