<T> 具有附加异常处理的异步任务超时

Question

在我的项目中，我引用了动态链接库中的类型和接口。 使用此特定库时，我要做的第一件事是创建一个EA.Repository实例，该实例在库中定义，并用作进一步使用的入口点。

实例化EA.Repository repository = new EA.Repository()在后台执行一些复杂的事情，我发现自己面临着三种可能的结果：

1. 实例化需要一些时间，但最终成功完成
2. 引发异常(立即或一段时间后)
3. 实例化永久停止(在这种情况下，我想取消并通知用户)

我能够提出一种异步方法，使用Task：

public static void Connect()
{
// Do the lengthy instantiation asynchronously
Task<EA.Repository> task = Task.Run(() => { return new EA.Repository(); });
bool isCompletedInTime;
try
{
// Timeout after 5.0 seconds
isCompletedInTime = task.Wait(5000);
}
catch (Exception)
{
// If the instantiation fails (in time), throw a custom exception
throw new ConnectionException();
}
if (isCompletedInTime)
{
// If the instantiation finishes in time, store the object for later
EapManager.Repository = task.Result;
}
else
{       
// If the instantiation did not finish in time, throw a custom exception
throw new TimeoutException();
}
}

(我知道，你可能已经在这里发现了很多问题。请耐心等待我...建议将不胜感激！

到目前为止，这种方法有效 - 我可以模拟"异常"和"超时"场景，并获得所需的行为。

但是，我发现了另一种边缘情况：假设实例化任务需要足够长的时间，以至于超时过期，然后引发异常。在这种情况下，我有时会以AggregateException告终，说任务没有被观察到。

我正在努力寻找可行的解决方案。当超时到期时，我无法真正取消任务，因为阻塞实例化显然阻止我使用CancellationToken方法。

我唯一能想到的就是在抛出我的自定义TimeoutException之前开始异步观察任务(即启动另一个任务)：

Task observerTask = Task.Run(() => {
try { task.Wait(); }
catch (Exception) { }
});
throw new TimeoutException();

当然，如果实例化真的永远停止，我已经有第一个任务永远不会完成。有了观察者任务，现在我什至有两个！

我对这整个方法非常不安全，所以欢迎任何建议！

提前非常感谢！

Answer 1

我不确定我是否完全理解您要实现的目标，但是如果您这样做怎么办 -

public static void Connect()
{
Task<EA.Repository> _realWork = Task.Run(() => { return new EA.Repository(); });
Task _timeoutTask = Task.Delay(5000);
Task.WaitAny(new Task[]{_realWork, timeoutTask});
if (_timeoutTask.Completed)
{
// timed out
}
else
{
// all good, access _realWork.Result
}
}

或者你甚至可以缩短一点——

public static void Connect()
{
Task<EA.Repository> _realWork = Task.Run(() => { return new EA.Repository(); });
var completedTaskIndex = Task.WaitAny(new Task[]{_realWork}, 5000);
if (completedTaskIndex == -1)
{
// timed out
}
else
{
// all good, access _realWork.Result
}
}

您也可以始终使用超时的CancellationToken调用Task.Run，但会引发异常 - 上述解决方案使您可以控制行为而不会引发异常(即使您始终可以try/catch)

Answer 2

下面是一个扩展方法，可用于显式观察在未观察到时可能失败的任务：

public static Task<T> AsObserved<T>(this Task<T> task)
{
task.ContinueWith(t => t.Exception);
return task;
}

使用示例：

var task = Task.Run(() => new EA.Repository()).AsObserved();