async/await模型中异步事件取消机制与CancellationToken传递咨询

当前代码的问题 #

你贴出的DelegateExtensions.InvokeAsync方法完全没有实现取消机制：它既不接受CancellationToken参数，也不会在调用委托时传递任何取消信号，所以当前模型无法触发异步事件处理的取消操作。

如何实现取消机制与令牌传递 #

要让这个模型支持取消，需要从委托定义和扩展方法两方面修改，常见有两种实现方式：

方案一：修改委托类型，直接传递CancellationToken #

调整扩展方法的签名，新增CancellationToken参数，同时要求事件处理委托接受该令牌：

public static class DelegateExtensions
{
    public static Task InvokeAsync<TArgs>(this Func<object, TArgs, CancellationToken, Task> func, object sender, TArgs e, CancellationToken cancellationToken)
    {
        if (func == null) return Task.CompletedTask;
        
        // 提前检查令牌状态，避免无意义的委托调用
        cancellationToken.ThrowIfCancellationRequested();
        
        return Task.WhenAll(
            func.GetInvocationList()
                .Cast<Func<object, TArgs, CancellationToken, Task>>()
                .Select(f => f(sender, e, cancellationToken))
        );
    }
}

工作逻辑：

• 外部调用InvokeAsync时传入CancellationToken（通常来自CancellationTokenSource）。
• 扩展方法先检查令牌是否已取消，若已取消直接抛出OperationCanceledException，终止后续操作。
• 每个事件处理委托拿到令牌后，可以在自身的异步操作中使用（比如await DatabaseQueryAsync(cancellationToken)），当令牌触发取消时，异步操作会自动终止并抛出异常，最终Task.WhenAll会汇总所有委托的状态。

方案二：将CancellationToken嵌入事件参数 #

如果不想修改委托类型，可以扩展事件参数类，把令牌作为参数的一部分：

// 定义带取消令牌的事件参数
public class CancelableEventArgs : EventArgs
{
    public CancellationToken CancellationToken { get; }
    
    public CancelableEventArgs(CancellationToken cancellationToken)
    {
        CancellationToken = cancellationToken;
    }
}

对应的扩展方法可以保持原有签名，但事件处理委托需要从参数中提取令牌：

public static class DelegateExtensions
{
    public static Task InvokeAsync<TArgs>(this Func<object, TArgs, Task> func, object sender, TArgs e)
        where TArgs : CancelableEventArgs
    {
        if (func == null) return Task.CompletedTask;
        
        // 提前检查令牌状态
        e.CancellationToken.ThrowIfCancellationRequested();
        
        return Task.WhenAll(
            func.GetInvocationList()
                .Cast<Func<object, TArgs, Task>>()
                .Select(f => f(sender, e))
        );
    }
}

工作逻辑：

• 触发事件时，创建带取消令牌的CancelableEventArgs实例传入。
• 事件处理委托从e.CancellationToken获取令牌，在内部异步操作中使用，当外部触发取消时，委托内的异步操作会响应终止。

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