没有 TaskCompletionSource 的任务链？

Question

我正在将一些异步/等待代码转换为链接任务，以便我可以在已发布的框架中使用它。等待代码如下所示

public async Task<TraumMessage> Get() {
  var message = await Invoke("GET");
  var memorized = await message.Memorize();
  return memorized;
}

，

Task<TraumMessage> Invoke(string verb) {}
Task<TraumMessage> Memorize() {}

我希望链接 Invoke 和 Memorize 以返回由 Memorize 生成的任务，但这会导致 <代码>任务<任务。我最终得到的解决方案是使用 TaskCompletionSource 作为我的信号：

public Task<TraumMessage> Get() {
  var completion = new TaskCompletionSource<TraumMessage>();
  Invoke("GET").ContinueWith( t1 => {
     if(t1.IsFaulted) {
       completion.SetException(t1.Exception);
       return;
     }
     t1.Result.Memorize().ContinueWith( t2 => {
       if(t2.IsFaulted) {
         completion.SetException(t2.Exception);
         return;
       }
       completion.SetResult(t2.Result);
     });
  });
  return completion.Task;
}

有没有办法在没有 TaskCompletionSource 的情况下完成此任务？

Answer 1

是的，该框架附带了一个方便的 Unwrap() 扩展方法，可以满足您的需求。

Invoke("GET").ContinueWith( t => t.Result.Memorize() ).Unwrap();

如果您要取消，那么显然您需要将取消令牌传递到适当的位置。

Answer 2

我认为这几乎是实现你想要的目标的唯一方法。延续 API 不支持将不同的任务链接在一起，因此您必须使用 TaskCompletionSource 就像协调工作一样。

我没有在这台机器上安装 Async CTP，但是为什么你不使用反编译器（或者 ILDASM，如果你知道如何阅读 IL）来查看代码，看看它在做什么。我敢打赌它在幕后所做的事情与你的 TCS 代码非常相似。

Answer 3

您可以使用附加的子任务。只有当所有子任务都完成时，父任务才会转换为已完成状态。异常会传播到父任务。
您将需要一个结果持有者，因为结果将在父任务的委托完成后分配，但会在父任务延续运行时设置。

像这样：

public class Holder<T> where T: class
{
   public T Value { get; set; }
}

public Task<Holder<TraumMessage>> Get() {
  var invokeTask = Invoke("GET");
  var result = invokeTask.ContinueWith<Holder<TraumMessage>>(t1 => {
    var holder = new Holder<TraumMessage>();
    var memorizeTask = t1.Result.Memorize();
    memorizeTask.ContinueWith(t2 => {
      holder.Value = t2.Result;
    }, TaskContinuationOptions.AttachedToParent);
    return holder;
  });
  return result;
}