如何从其他任务向主任务触发OperationCanceledException异常

• 未观测后台异步任务的异常：通过Task.Run启动的后台异步任务抛出的异常会被封装在任务对象内部，不会自动冒泡到启动任务的外层线程栈的try/catch块中。只有当你await该任务、调用Wait()/访问Result属性时，异常才会被抛出到当前线程，你当前测试代码启动任务后没有做任何任务状态观测，自然捕获不到异常。
• 缺少业务层的取消检查逻辑：你原设计的逻辑是心跳任务仅负责触发取消信号，真正的OperationCanceledException是由业务代码各个执行节点调用的IsContinue()方法抛出的，你当前测试代码的「其他业务代码」部分完全没有调用取消检查方法，不会主动触发异常。
• 测试逻辑缺失关键标记：你原本的逻辑中有两个独立的取消标记，一个用于心跳任务自身的退出，一个用于通知业务任务取消，你的测试代码只实现了心跳任务的标记，没有实现业务任务对应的TaskTokenSource和配套的IsContinue()检查逻辑。

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

class Program
{
    // 业务任务取消标记（对应你原有逻辑的TaskToken）
    static CancellationTokenSource TaskTokenSource;
    static CancellationToken TaskToken;
    // 心跳任务取消标记
    static CancellationTokenSource IsAliveTokenSource;
    static CancellationToken IsAliveToken;

    // 你原有的检查方法
    public static void IsContinue()
    {
        if (TaskToken.IsCancellationRequested)
            TaskToken.ThrowIfCancellationRequested();
    }

    static async Task Main(string[] args)
    {
        TaskTokenSource = new CancellationTokenSource();
        TaskToken = TaskTokenSource.Token;
        IsAliveTokenSource = new CancellationTokenSource();
        IsAliveToken = IsAliveTokenSource.Token;

        try
        {
            // 启动心跳任务，保存任务引用用于后续观测异常
            var heartbeatTask = Task.Run(async () =>
            {
                int attempts = 0;
                bool isAlive = true;
                while (true)
                {
                    if (attempts == 3)
                        isAlive = false;
                    attempts++;

                    Console.WriteLine($"Task status: {isAlive}");
                    if (!isAlive)
                    {
                        // 同时取消业务任务和心跳任务
                        TaskTokenSource.Cancel();
                        IsAliveTokenSource.Cancel();
                    }

                    await Task.Delay(1000); // 这里改短间隔方便快速测试

                    if (IsAliveToken.IsCancellationRequested)
                    {
                        Console.WriteLine($"End heartbeat task");
                        IsAliveToken.ThrowIfCancellationRequested();
                    }
                }
            });

            // 模拟你的算法业务代码，循环执行+调用IsContinue检查
            while (true)
            {
                IsContinue();
                Console.WriteLine("业务代码执行中...");
                await Task.Delay(500);
            }
        }
        catch (OperationCanceledException)
        {
            Console.WriteLine("Task is terminated");
        }
        catch (Exception ex)
        {
            Console.WriteLine(ex);
        }
    }
}

如果需要心跳任务的异常也能被单独捕获，可以把heartbeatTask也加入等待逻辑，或者给TaskToken注册取消回调，满足不同的业务场景需求。如果要让算法任务尽可能快地响应取消，只需要在算法的每个可中断的执行节点都调用一次IsContinue()即可。

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