如何使用 cancellationTokens 释放 LongRunningTask

问：

与这个问题相关：我需要取消 signalR 中的长时间运行循环，我该怎么做？

我设置了一种快速的方法来更好地了解自己的情况，并找到了半个解决方案。我能够取消任务（不确定如何取消，因为 CancellationTokenSource 在 .Cancel（） 但无论如何）。但似乎有一个新问题。这是我当前的测试代码：

服务器端集线器：

public class MyHub : Hub<IMyHub>
    {
        private CancellationTokenSource cancellationTokenSource;

        public void StartLongRunningTask()
        {
            cancellationTokenSource = new CancellationTokenSource();

            try
            {
                LongRunningTask(cancellationTokenSource.Token);
                // Task completed successfully
            }
            catch (TaskCanceledException)
            {
                // Task was canceled by the client
                // Handle cancellation logic here
            }
            finally
            {
                cancellationTokenSource.Dispose();
            }
        }

        public async void CancelLongRunningTask()
        {
            cancellationTokenSource?.Cancel();

            await Clients.All.SendStatus(false);
        }

        private void LongRunningTask(CancellationToken ct)
        {
            // Your long-running task implementation
            // Ensure to check the cancellation token periodically and stop processing if canceled
            while (!ct.IsCancellationRequested)
            {
                _ = Clients.Caller.SendStatus(true);

                _ = Task.Delay(1000, ct);
                // Continue with other work...
            }
        }
    }

客户端调用方：

public class IndexModel : PageModel
    {
        private readonly ILogger<IndexModel> _logger;

        private readonly HubConnection _hubConnection;

        public bool Running { get; set; }
        public string Status { get; set; }

        public IndexModel(ILogger<IndexModel> logger)
        {
            _logger = logger;

            _hubConnection = new HubConnectionBuilder()
                .WithUrl("https://localhost:7127/myhub") // Replace with the actual URL of your SignalR hub
                .Build();

            _ = _hubConnection.StartAsync();

            _hubConnection.On<bool>("SendStatus", (status) =>
            {
                Running = status;
            });
        }

        public async Task OnGetAsync()
        {
            // Start the SignalR connection
        }

        public async Task<IActionResult> OnPostOpenAsync(IFormCollection data)
        {
            Status = _hubConnection.State.ToString();

            return Page();
        }

        public async Task<IActionResult> OnPostStartAsync(IFormCollection data)
        {
            _ = _hubConnection.InvokeAsync("StartLongRunningTask");

            Status = _hubConnection.State.ToString();

            return Page();
        }

        public async Task<IActionResult> OnPostCancelAsync(IFormCollection data)
        {
            await _hubConnection.InvokeAsync("CancelLongRunningTask");

            Status = _hubConnection.State.ToString();

            return Page();
        }

    }

你可以猜到打开、启动和取消功能后面有按钮。但这里发生了几件有趣的事情。

1. 如果我等待 LongRunningTask 的调用，它会等到它完成，但永远不会等到我取消它。到目前为止，这对我来说是合乎逻辑的。

2. 但是当我不等待 LongRunningTask（CancellationTokenSource.Token）;在服务器中心。它不应该等待这个任务完成，对吧？还是我在这里遗漏了什么？

3. 我不确定为什么，但是Clients.Caller.SendStatus（true）不会发送任何内容，直到我将其移动到服务器中心中的StartlongRunningTask（）。我能想到一个原因，但我不确定，如果有人能向我解释这种行为，那就太好了。

4. 最后但并非最不重要的一点是，我写这篇文章的核心原因。如果我在客户端等待调用，它将在我单击取消之前等待。但是当我这样做时，结果是内存和 CPU 使用率：

第一条蓝线是我启动长时间运行的任务的位置，第二条蓝线是我取消任务的位置。我相信不知何故，任务一直在后台运行，但一旦我单击，前端就会停止加载，并且触发了服务器集线器上的“CancelLongRunningTask”。那么这到底是怎么发生的呢？前端停止加载，但在后台保持循环？如果有人能向我解释这种行为，那就太好了！

编辑

在等待了 Canton7 建议的一切之后，还有一个问题需要回答，因为 CancelLongRunningTask（） 函数在空令牌上调用 Cancel？除此之外，.SendStatus（true） 从不发送？