2

我有一个 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>

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

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

4

1 回答 1

6

问题是Queue<Task>. Task单独没有Result财产。但是，Task<Foo>具有Resulttype 的属性Foo。（我不知道client.Get(...)返回什么，我们暂时称它为Foo：

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

该ContinueWhenAll方法不支持Queue<>, 只支持Task[]and Task<>[]，所以需要先将其转为数组。

Task.Factory.ContinueWhenAll(
    taskQueue.ToArray(),
    tasks =>
    {
        var results = tasks.Select(t => t.Result);
        foreach (var result in results)
        {
            ...
        }
    });
}
于 2012-06-06T15:44:03.833 回答