好的,我已经找到了这个问题。该错误的细节可能不如我用来查找它的方法有趣,但我将在下面的单独部分中介绍这两者。
问题
这是有问题的代码的一部分:
private static Task<TSuccessor> ThenImpl<TAntecedent, TSuccessor>(Task<TAntecedent> antecedent, Func<Task<TAntecedent>, Task<TSuccessor>> getSuccessor, CancellationToken cancellationToken, TaskThenOptions options)
{
antecedent.AssertNotNull("antecedent");
getSuccessor.AssertNotNull("getSuccessor");
var taskCompletionSource = new TaskCompletionSource<TSuccessor>();
antecedent.ContinueWith(
delegate
{
var evenOnFaulted = options.HasFlag(TaskThenOptions.EvenOnFaulted);
var evenOnCanceled = options.HasFlag(TaskThenOptions.EvenOnCanceled);
if (antecedent.IsFaulted && !evenOnFaulted)
{
taskCompletionSource.TrySetException(antecedent.Exception.InnerExceptions));
}
else if ((antecedent.IsCanceled || cancellationToken.IsCancellationRequested) && !evenOnCanceled)
{
taskCompletionSource.TrySetCanceled();
}
else
{
此方法支持我的Then
扩展方法,我在博客中提到了.
除了在我的博客文章中的实现之外,我最近添加了运行“然后继续”的能力,我称之为,即使前面的任务出错:
Task.Factory.StartNew(() => { throw new InvalidOperationException(); })
.Then(() => Console.WriteLine("Executed"), TaskThenOptions.EvenOnFaulted);
这将导致初始异常被忽略并在控制台上输出“已执行”。但是,问题是我ThenImpl
没有观察到原来的异常。为此,我改变了这一行:
if (antecedent.IsFaulted && !evenOnFaulted)
对此:
if (antecedent.Exception != null && !evenOnFaulted)
现在我不明白这个问题。
现在,您可能想知道为什么这很难追查。问题是,我有很多促进高级场景的任务组合方法。这是一个实际的片段,可让您了解所产生的力量:
private Task OnConnectAsync(CancellationToken cancellationToken, object state)
{
var firstAttempt = true;
var retryOnFailureTask = TaskUtil
.RetryOnFailure(
() => TaskUtil.Delay(firstAttempt ? TimeSpan.Zero : this.reconnectDelay, cancellationToken)
.Then(
x =>
{
if (!firstAttempt)
{
Interlocked.Increment(ref this.connectionAttempts);
}
firstAttempt = false;
})
.Then(x => this.loggerService.Debug("Attempting to connect communications service (attempt #{0}).", this.connectionAttempts), cancellationToken)
.Then(x => this.communicationsService.ConnectAsync(cancellationToken), cancellationToken)
.Then(x => this.loggerService.Debug("Successfully connected communications service (attempt #{0}).", this.connectionAttempts), cancellationToken)
.Then(x => this.communicationsService.AuthenticateAsync(cancellationToken), cancellationToken)
.Then(x => this.loggerService.Debug("Successfully authenticated communications service (attempt #{0}).", this.connectionAttempts), cancellationToken)
.Then(x => this.ReviveActiveStreamsAsync(cancellationToken), cancellationToken)
.Then(x => this.loggerService.Debug("Successfully revived streams (attempt #{0}).", this.connectionAttempts), cancellationToken),
null,
cancellationToken);
return retryOnFailureTask;
}
注意 custom RetryOnFailure
、Then
和Delay
方法。这是我在谈论的一个很好的品味。
当然,这样做的缺点是在问题发生时跟踪问题。我不禁觉得TPL在这方面做得很差。在我看来,每个都Task
应该包含有关谁创建它的信息。至少,TPL 中应该有钩子(例如TaskCreated
事件),以便开发人员可以用他们自己的调试信息来补充任务。使用 .NET 4.5 可能会改善这种情况 - 不过我正在使用 .NET 4.0。
方法
追查问题的关键是费力地包装Task
我创建的每一个TaskCompletionSource
,用补充信息包装任何异常。例如,这是ToBooleanTask
我事先拥有的扩展方法:
public static Task<bool> ToBooleanTask(this Task task)
{
var taskCompletionSource = new TaskCompletionSource<bool>();
task.ContinueWith(
x =>
{
if (x.IsFaulted)
{
taskCompletionSource.TrySetException(x.Exception.GetBaseException());
}
else if (x.IsCanceled)
{
taskCompletionSource.TrySetCanceled();
}
else
{
taskCompletionSource.TrySetResult(true);
}
});
return taskCompletionSource.Task;
}
这是在进行此更改之后:
public static Task<bool> ToBooleanTask(this Task task)
{
var taskCompletionSource = new TaskCompletionSource<bool>();
task.ContinueWith(
x =>
{
if (x.IsFaulted)
{
taskCompletionSource.TrySetException(new InvalidOperationException("Failure in to boolean task", x.Exception.GetBaseException()));
}
else if (x.IsCanceled)
{
taskCompletionSource.TrySetCanceled();
}
else
{
taskCompletionSource.TrySetResult(true);
}
});
return taskCompletionSource.Task;
}
在这种情况下,我已经有了一个TaskCompletionSource
,所以它很简单。在其他情况下,我必须显式创建一个TaskCompletionSource
并将任何故障/取消/结果从底层转发Task
到TaskCompletionSource
.
旁白:您可能想知道ToBooleanTask
扩展方法的使用。如果您想实现一个同时处理通用和非通用任务的方法,它非常有用。您可以实现泛型版本,然后调用非泛型重载ToBooleanTask
以创建泛型任务,然后将其传递给泛型重载。
一旦我检查了所有可能的罪魁祸首并按照上述补充了它们,我重新运行了我的测试,直到它失败并注意到它确实ToBooleanTask
是在创建没有被观察到的任务。因此,我将其修改为:
public static Task<bool> ToBooleanTask(this Task task)
{
var stackTrace = new System.Diagnostics.StackTrace(true);
var taskCompletionSource = new TaskCompletionSource<bool>();
task.ContinueWith(
x =>
{
if (x.IsFaulted)
{
taskCompletionSource.TrySetException(new InvalidOperationException("Failure in to boolean task with stack trace: " + stackTrace, x.Exception.GetBaseException()));
}
else if (x.IsCanceled)
{
taskCompletionSource.TrySetCanceled();
}
else
{
taskCompletionSource.TrySetResult(true);
}
});
return taskCompletionSource.Task;
}
当失败发生时,这会给我一个完整的堆栈跟踪。我重新运行了我的测试,直到它失败,并且 - 万岁!- 获得了我需要追踪问题的信息:
Failure in to boolean task with stack trace: at XXX.Utility.Tasks.TaskExtensions.ToBooleanTask(Task task) in C:\XXX\Src\Utility\Tasks\TaskExtensions.cs:line 110
at XXX.Utility.Tasks.TaskExtensions.Then(Task antecedent, Func`2 getSuccessor, CancellationToken cancellationToken, TaskThenOptions options) in C:\XXX\Src\Utility\Tasks\TaskExtensions.cs:line 199
at XXX.Utility.Tasks.StateMachineTaskFactory`1.TransitionTo(T endTransitionState, CancellationToken cancellationToken, WaitForTransitionCallback`1 waitForTransitionCallback, ValidateTransitionCallback`1 validateTransitionCallback, PreTransitionCallback`1 preTransitionCallback, Object state) in C:\XXX\Src\Utility\Tasks\StateMachineTaskFactory.cs:line 312
<snip>
所以我可以看到这是我的Then
重载调用之一ToBooleanTask
。然后我可以追踪那个确切的代码,问题很快就变得明显了。
不过,这让我很好奇。为什么我最初用名称补充每个任务的方法没有产生任何结果?我尝试恢复我的修复,直接命名由 生成的任务ToBooleanTask
,然后重新运行,直到失败。果然,我在调试器中看到了任务名称。很明显,我最初以某种方式错过了命名这个任务。
呸!