使用可能挂起的 API 强制取消任务

Question

我目前正在使用串行端口，即使设置了自己的超时，我使用的 API 有时也会在读取时挂起。

这不是一个大问题，但是当发生这种情况并且需要关闭挂起的线程时，我需要做一些工作。我已经尝试过以下方法，但它一直给我带来问题，因为 API 调用没有终止，但允许在其余代码继续时继续，并且抛出了 TimeoutException。如何使用Tasks 在一定时间后取消挂起的任务？

CancellationToken token = new CancellationToken();
var task = Task.Factory.StartNew(() => 
           {
               CallingAPIThatMightHang(); // Example
           }, token);

if (!task.Wait(this.TimeToTimeOut, token))
{
    throw new TimeoutException("The operation timed out");
}

Answer 1

CancellationToken是合作取消的形式。您需要在执行操作时调节令牌并观察是否已请求取消。

从您的代码块来看，您似乎有一个长时间运行的同步操作，您将其卸载到线程池线程。如果是这种情况，请查看是否可以将该串行调用分离到块，您可以在读取块后轮询令牌。如果您不能，则无法取消。

请注意，为了请求取消，您必须创建一个 CancellationTokenSource，稍后您可以将其称为 Cancel() 方法。

附带说明一下，串口是异步 IO，您可以自然地使用异步 API，而不是将同步卸载到线程池线程。

编辑：

@HansPassant 给出了一个更好的主意。在另一个进程中运行第三方调用，你保留一个引用。一旦您需要终止它，请终止该进程。

例如：

void Main()
{
    SomeMethodThatDoesStuff();
}

void SomeMethodThatDoesStuff()
{
   // Do actual stuff
}

然后在单独的进程中启动它：

private Process processThatDoesStuff;

void Main()
{
    processThatDoesStuff = Process.Start(@"SomeLocation");
    // Do your checks here.

    if (someCondition == null)
    {
        processThatDoesStuff.Kill();
    }
}

如果您需要在这两个进程之间传递任何结果，您可以通过多种机制来完成。一种是写入和读取该过程的标准输出。

Answer 2

很遗憾，我无法使用任何其他框架，也无法更改我正在调用的 API，以便它可以使用取消令牌。

这就是我选择解决问题的方式。

class Program
{
    static void Main(string[] args)
    {
        try
        {
            var result = TestThreadTimeOut();
            Console.WriteLine("Result: " + result);
        }
        catch (TimeoutException exp)
        {
            Console.WriteLine("Time out");
        }
        catch (Exception exp)
        {
            Console.WriteLine("Other error! " + exp.Message);
        }

        Console.WriteLine("Done!");
        Console.ReadLine();
    }

    public static string TestThreadTimeOut()
    {
        string result = null;
        Thread t = new Thread(() =>
        {
            while (true)
            {
                Console.WriteLine("Blah Blah Blah");
            }
        });
        t.Start();
        DateTime end = DateTime.Now + new TimeSpan(0, 0, 0, 0, 1500);
        while (DateTime.Now <= end)
        {
            if (result != null)
            {
                break;
            }
            Thread.Sleep(50);
        }
        if (result == null)
        {
            try
            {
                t.Abort();
            }
            catch (ThreadAbortException)
            {
                // Fine
            }
            throw new TimeoutException();
        }
        return result;
    }
}