3

我正在查看 codeplex 上的下载管理器类型项目，并遇到了这个： http: //nthdownload.codeplex.com/

浏览我在AddDownloads下面列出的方法中运行的代码：

AddDownloads启动 _downloadQueue.AddDownloads 任务并继续执行该viewMaintenanceTask任务。如果您查看这 2 个任务和下游发生的方法和事情，似乎一切都是同步的。

还阅读这篇博文，同步任务与任务我试图了解将同步方法包装在TaskCompletionSource. 是因为它为 API 使用者提供了在单独的线程上启动任务的选项，还是仅仅因为您想将该方法用作Task. 同步方法是否TaskCompletionSource受益于并行处理？

private Task<QueueOperation> AddDownloads(IEnumerable<IDownload> downloads, out Task<QueueOperation> startTask)
{
    var addTask = _downloadQueue.AddDownloads(downloads, out startTask);

    // Maintain views
    var viewMaintenanceTask = addTask.ContinueWith(t =>
    {
        if (t.Exception == null)
        {
            var addedDownloads = t.Result.DownloadErrors.Where(k => k.Value == null).Select(k => k.Key).ToList();
            var activeDownloads = ActiveDownloads.ToList();
            AddToActiveDownloads(addedDownloads.Except(activeDownloads).ToList(), false);
        }
        else
        {
            // Rethrow exception, this ensures it'll bubble up to any further ContinueWith chained off this task
            throw t.Exception;
        }
        return t.Result;
    });

    return viewMaintenanceTask;
}

博客文章中的示例方法，将同步操作包装在TaskCompletionSource：

var tcs = new TaskCompletionSource<object>();

try
{
    object result = model.Deserialize(stream, null, type);
    tcs.SetResult(result);
}
catch (Exception ex)
{
    tcs.SetException(ex);
}

return tcs.Task;
4

1 回答 1

9

包装在 TaskCompletionSource 中的同步方法是否受益于并行处理？

不会。创建 aTaskCompletionSource不会以任何方式、形状或形式创建新线程。

您在底部给出的代码毫无意义——当方法返回时，任务已经完成（或出错）。如果您必须使用任务，它只会有任何用处。我可能会将其更改为：

try
{
    return Task.FromResult(model.Deserialize(stream, null, type));
}
catch (Exception ex)
{
    // There's no Task.FromException, unfortunately.
    var tcs = new TaskCompletionSource<object>();
    tcs.SetException(ex);
    return tcs.Task;
}

在 C# 中，这相当于编写async没有await表达式的方法：

public static async Task<object> Deserialize(Model model, Stream stream,
                                             Type type)
{
    return model.Deserialize(stream, null, type);
}

如果您想要真正的并行性，您应该使用Task.Run(.NET 4.5) 或Task.Factory.StartNew(.NET 4)。

于 2012-11-03T19:19:47.193 回答