retry-task-policy.md

🔁 WithRetry Helper for C#

A minimal retry utility for async methods with and without return values.

📦 Code

using System;
using System.Threading;
using System.Threading.Tasks;

public static class WithRetry
{
    /// <summary>
    /// Retries an asynchronous function that returns a result (Task&lt;T&gt;).
    /// </summary>
    public static async Task<T> TaskAsync<T>(Func<Task<T>> operation, int maxRetries = 2, TimeSpan? delay = null, CancellationToken cancellationToken = default)
    {
        if (operation == null) throw new ArgumentNullException(nameof(operation));
        if (maxRetries < 0) throw new ArgumentOutOfRangeException(nameof(maxRetries));

        delay = delay ?? TimeSpan.FromSeconds(1);

        for (int attempt = 1; ; attempt++)
        {
            try
            {
                cancellationToken.ThrowIfCancellationRequested();
                return await operation().ConfigureAwait(false);
            }
            catch (Exception ex) when (attempt < maxRetries)
            {
                Console.WriteLine($"[Attempt {attempt}] Failed, Error: {ex.Message}");
                await Task.Delay(delay.Value, cancellationToken).ConfigureAwait(false);
            }
        }
    }

    /// <summary>
    /// Retries an asynchronous function that does not return a result (Task).
    /// </summary>
    public static async Task TaskAsync(Func<Task> operation, int maxRetries = 2, TimeSpan? delay = null, CancellationToken cancellationToken = default)
    {
        if (operation == null) throw new ArgumentNullException(nameof(operation));
        if (maxRetries < 0) throw new ArgumentOutOfRangeException(nameof(maxRetries));

        delay = delay ?? TimeSpan.FromSeconds(1);

        for (int attempt = 1; ; attempt++)
        {
            try
            {
                cancellationToken.ThrowIfCancellationRequested();
                await operation().ConfigureAwait(false);
                return;
            }
            catch (Exception ex) when (attempt < maxRetries)
            {
                Console.WriteLine($"[Attempt {attempt}] Failed, Error: {ex.Message}");
                await Task.Delay(delay.Value, cancellationToken).ConfigureAwait(false);
            }
        }
    }
}