如何优雅实现按间隔运行任务，满足条件或超时后停止？

嘿，我刚好处理过类似的需求！你之前的两种尝试其实都差一点，把Task.Delay和CancellationTokenSource结合起来就能完美解决——既能按间隔重复跑，又能灵活触发停止（不管是超时还是自定义条件），而且全程异步非阻塞，代码还很优雅。

这个方案的核心是用异步循环+Task.Delay控制间隔，用CancellationTokenSource统一处理所有停止触发场景：超时、自定义条件、外部取消信号。

通用重复执行工具类 #

我写了一个通用的工具方法，你可以直接复用：

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

public static class RepeatExecutionHelper
{
    public static async Task RunRepeatedlyAsync(
        Func<CancellationToken, Task> targetAction, // 要重复执行的异步方法
        TimeSpan executionInterval, // 两次执行之间的间隔
        TimeSpan? totalTimeout = null, // 可选：最长运行时长，超时自动停止
        Func<bool>? stopWhen = null, // 可选：自定义停止条件，返回true时停止
        CancellationToken externalCancelToken = default) // 可选：外部传入的取消令牌，比如用户主动停止
    {
        // 绑定多个取消信号：外部令牌 + 内部超时/条件令牌
        using var combinedCts = CancellationTokenSource.CreateLinkedTokenSource(externalCancelToken);

        // 如果设置了总超时，自动在超时后触发取消
        if (totalTimeout.HasValue)
        {
            combinedCts.CancelAfter(totalTimeout.Value);
        }

        try
        {
            while (!combinedCts.Token.IsCancellationRequested)
            {
                // 执行目标操作，传入取消令牌确保操作能及时响应停止
                await targetAction(combinedCts.Token);

                // 检查自定义停止条件，满足就触发取消
                if (stopWhen?.Invoke() == true)
                {
                    combinedCts.Cancel();
                    break;
                }

                // 等待指定间隔，期间如果收到取消信号会直接抛出OperationCanceledException
                await Task.Delay(executionInterval, combinedCts.Token);
            }
        }
        catch (OperationCanceledException)
        {
            // 取消是预期行为，这里可以根据需求加日志，或者直接忽略
            Console.WriteLine("重复执行已停止：超时/满足停止条件/外部取消");
        }
    }
}

怎么用这个工具类？ #

给你一个实际的调用示例，比如每2秒执行一次，要么执行满5次停止，要么运行超过15秒自动停止：

async Task ExampleUsage()
{
    int executionCounter = 0;
    const int MaxExecutions = 5;

    await RepeatExecutionHelper.RunRepeatedlyAsync(
        targetAction: async (token) =>
        {
            executionCounter++;
            Console.WriteLine($"第 {executionCounter} 次执行，当前时间：{DateTime.Now:HH:mm:ss}");
            
            // 模拟你的业务操作，记得传入令牌确保能被取消
            await Task.Delay(200, token);
        },
        executionInterval: TimeSpan.FromSeconds(2),
        totalTimeout: TimeSpan.FromSeconds(15),
        stopWhen: () => executionCounter >= MaxExecutions
    );
}

为什么这个方案比你之前的尝试更好？ #

• 对比Task+CancellationToken：你之前可能没把循环和Task.Delay结合起来，这个方案用异步循环+Task.Delay完美实现了间隔控制，而且全程响应取消信号
• 对比System.Threading.Timer：Timer的回调是在线程池线程，异步操作不好处理，而且取消Timer需要手动调用Dispose，还可能出现回调在Dispose后仍执行的问题；这个方案全程异步可控，取消逻辑统一在CancellationTokenSource里，更安全

内容的提问来源于stack exchange，提问作者ohadinho