使用任务并行库 a la wait 转换 void 任务的异常

Question

我需要以与正常同步代码执行以下操作相同的方式转换从 Task 发出的异常：

try {
  client.Call();
} catch(FaultException ex) {
    if (ex.<Some check>)
        throw new Exception("translated");
}

但是，我想异步执行此操作，即 Call<上面的 /code> 实际上是 Task CallAsync()。

因此，在 C# 5 中，我的方法将如下所示：

async Task CallAndTranslate()
{
    try{
        await client.CallAsync();
    } catch(FaultException ex) {
        if (ex.FaultCode ...)
            throw new Exception("translated");
    }
}

但我现在使用 C# 4。

那么，如果我想触发一个任务，但要转换 (TPL) 故障，然后再次将整个事件作为 Task 公开，我该怎么办？

• 最初源自 WCF Web 服务，但这在这里并不重要

编辑：更具体的说法：

public class TranslatingExceptions
{
    public Task ApiAsync() // The inner layer exposes it exactly this way
    {
        return Task.Factory.StartNew(()=>{ throw new Exception( "Argument Null" );});
    }

    public Task WrapsApiAsync() // this layer needs to expose it exactly this way
    {
        // async preview pseudocode for what I need to do                            
        try {
            await ApiAsync(  );
        } catch (Exception exception){
            if( exception.Message == "Argument Null"  )
                throw new ArgumentNullException();
        }
    }

    [Fact]
    public void Works()
    {
        var exception = Record.Exception( () => 
            WrapsApiAsync().Wait());
        Assert.IsType<ArgumentNullException>( exception.InnerException);
    }
}

如何在不需要 C# 5 的情况下实现 WrapsApiAsync()？

Answer 1

好的，现在我完全清楚您在寻找什么，这就是您在 4.0 中构建等效项所需要做的所有事情：

public class TranslatingExceptions
{
    public Task ApiAsync() // The inner layer exposes it exactly this way
    {
        return Task.Factory.StartNew(()=>{ throw new Exception( "Argument Null" );});
    }

    public Task WrapsApiAsync() // this layer needs to expose it exactly this way
    {
        // Grab the task that performs the "original" work
        Task apiAsyncTask = ApiAsync();

        // Hook a continuation to that task that will do the exception "translation"
        Task result = aspiAsync.ContinueWith(antecedent =>
        {
            // Check if the antecedent faulted, if so check what the exception's message was
            if ( antecedent.IsFaulted 
              && antecedent.Exception.InnerException.Message == "Argument Null" )
            {
                throw new ArgumentNullException();
            }
        },
        TaskContinuationOptions.ExecuteSynchronously);

        // Now we return the continuation Task from the wrapper method so that the caller of the wrapper method waits on that
        return result;
    }

    [Fact]
    public void Works()
    {
        var exception = Record.Exception(() => 
                                         WrapsApiAsync().Wait());

        Assert.IsType<ArgumentNullException>(exception.InnerException);
    }
}

这应该可以实现您正在寻找的内容。需要注意的一件事是，我在创建延续时使用 TaskContinuationOptions.ExecuteSynchronously。这是因为这项工作很小而且很紧张，您不希望因为等待调度程序从线程池中取出整个其他线程来执行此检查而产生开销。