c# - 捕获 CancelKeyPress 以在安全点停止异步控制台应用程序

Question

我正在开发一个小型实用程序控制台应用程序，内置于 C# 7.1(支持 async Main)。

该应用程序采用几个输入命令之一，然后启动一个长时间运行的过程，该过程迭代数以万计的项目，处理每个项目。

我希望能够随时取消此过程(使用 CTRL+C)，尽管程序不应该立即取消，而是应该完成当前迭代，然后停止。

这是迄今为止我所拥有的缩短版本。

private static bool _cancel;    

private static async Task Main(string[] args)
{
    Console.CancelKeyPress += (sender, eventArgs) =>
                                      {
                                          eventArgs.Cancel = true;                                              _logger("Migration will be stopped after the current record has been completed.\n");
                                          _cancel = true;
                                      };

    while (!_cancel)
    {
        var input = Console.ReadLine();

        // handle the various input commands
    }
}

在运行(可选)长时间运行进程的方法中，有一个逻辑检查这个全局 _cancel多变的:

private static async Task RunPersonMigration(Order order)
{
    var nextPerson = // ...
    while (nextPerson.IsValid)
    {
        // business logic

        if (_cancel)
        {
            _logger("Person migration stopped by user.\n");
            return;
        }

        nextPerson = // ...
    }
}

但是，每当我按 CTRL+C 时，Visual Studio 调试器都会要求我定位程序集，而且每次通常都是不同的程序集。例如，我被要求找到 waithandle.cs 和 thread.cs。因为我无法找到此类文件，正在运行的调试过程突然停止。

我永远看不到是哪一行导致了问题，而且没有多少断点有帮助。

基本上，我正在尝试使用 CTRL+C 退出长时间运行的进程而不退出控制台应用程序。

谁能告诉我应该如何正确处理在我选择的点取消长时间运行的控制台进程？

更新:
如果我更新我的 CancelKeyPress 代表...

Console.CancelKeyPress += (sender, eventArgs) =>
                                  {
                                      **eventArgs.Cancel = true;**                                              _logger("Migration will be stopped after the current record has been completed.\n");
                                      _cancel = true;
                                  };

那么这会阻止程序崩溃到关闭，但我仍然希望能够捕获 CTRL+C 并将其用作退出长时间运行的进程而不退出控制台应用程序本身的一种方式。这甚至可能吗？

Answer 1

使用 CancellationToken 的工作示例, 可以向下传递:

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

namespace ConsoleApp
{
    class Program
    {
        // Cancellation Tokens - https://docs.microsoft.com/en-us/previous-versions/dd997289(v=vs.110)
        private static readonly CancellationTokenSource canToken = new CancellationTokenSource();

        static async Task Main(string[] args)
        {
            Console.WriteLine("Application has started. Ctrl-C to end");

            Console.CancelKeyPress += (sender, eventArgs) =>
            {
                Console.WriteLine("Cancel event triggered");
                canToken.Cancel();
                eventArgs.Cancel = true;
            };

            await Worker();

            Console.WriteLine("Now shutting down");
            await Task.Delay(1000);
        }

        async static Task Worker()
        {
            while (!canToken.IsCancellationRequested)
            {
                // do work       
                Console.WriteLine("Worker is working");
                await Task.Delay(1000); // arbitrary delay
            }
        }
    }
}