重试之前的任务操作 TPL

我想实现一个重试任务，该任务采用先前失败的任务操作并重复它。

这是我到目前为止所拥有的。然而，它只是重复任务出错的事实，而不是再次实际触发任务的操作。

public static async Task<T> Retry<T>(this Task<T> task, int retryCount, int delay, TaskCompletionSource<T> tcs = null)
{
    if (tcs == null)
    {
        tcs = new TaskCompletionSource<T>();
    }

    await task.ContinueWith(async _original =>
    {
        if (_original.IsFaulted)
        {
            if (retryCount == 0)
            {
                tcs.SetException(_original.Exception.InnerExceptions);
            }
            else
            {
                Console.WriteLine("Unhandled exception. Retrying...");

                await Task.Delay(delay).ContinueWith(async t =>
                {
                    await Retry(task, retryCount - 1, delay, tcs);
                });
            }
        }
        else
            tcs.SetResult(_original.Result);
    });
    return await tcs.Task;
}

我试图通过一点反思来采取行动。然而，似乎一旦任务完成，操作就会设置为空。

var action = task
    .GetType()
    .GetField("m_action", BindingFlags.NonPublic | BindingFlags.Instance)
    .GetValue(task) as Action;

理想情况下，我希望我的实现如下所示：

try
{
    await MakeFailure().Retry(5, 1000);
}
catch (Exception ex)
{
    Console.WriteLine("I had an exception");
}

这可能不可能，但我想在将代码重构为Retry(Func<T> task)

并不完全反对。但它将代码流程更改为我不喜欢的故障优先布局

考虑一下你的类型。Task代表异步操作。在异步世界中，Task代表异步操作已经开始了. Task不是你可以“重试”的事情。

另一方面，Func<Task>表示可以启动的异步操作。或者重新启动。这就是你需要处理的。

一旦使用了适当的类型，代码就很简单：

public static async Task<T> Retry<T>(Func<Task<T>> action, int retryCount, int delay)
{
  while (retryCount > 0)
  {
    try
    {
      return await action().ConfigureAwait(false);
    }
    catch (Exception ex)
    {
      await Task.Delay(delay).ConfigureAwait(false);
      --retryCount;
    }
  }
  return await action().ConfigureAwait(false);
}

与其他回答者一样，我建议您使用实际上为此设计的库。这瞬态故障处理应用程序块 and Polly这是两个很好的例子。