c# - 如何从 C# 取消 C++/CX 中的异步操作

Question

我正在尝试从 C# 取消一个用 C++/CX 编写的操作。尽管我编写了这两段代码，但在从 C# 端等待时，我无法正确取消操作。这是一个例子:

来自 C#:

var tcs = new CancellationTokenSource();
tcs.Cancel();
var class1 = new MyClass();
try
{
    var asyncOp = await class1.DoSomeTaskAsync().AsTask(tcs.Token);
}
catch (OperationCanceledException oce)
{
    //I want to get here
    Handle(oce);
}

来自 C++:

IAsyncOperation<bool>^ MyClass::DoSomeTaskAsync(){
        return concurrency::create_async([](concurrency::cancellation_token ct) {
            task<bool> my_task([]() {
                doSomething1();
                if (concurrency::is_task_cancellation_requested())
                {
                    concurrency::cancel_current_task();
                }
                doSomething2();
                return false;
            }, ct);
            return my_task;
        });
    }

问题似乎是在通过 ABI 调用任务时，将 token 传递到 AsTask 扩展方法中没有任何作用。在调试 C++ 端时，ct 和 is_task_cancellation_requested() 函数均指示未请求取消。

Answer 1

试试这个。在你的 C++ Windows 运行时组件中做一些需要很长时间的事情，例如，concurrency::wait(2000) 将使线程休眠两秒钟(不要在真实的应用程序中这样做)。

#include <ppltasks.h>

using namespace Windows::Foundation;

IAsyncOperation<bool>^ MyClass::DoSomeTaskAsync()
{
    return concurrency::create_async([=](concurrency::cancellation_token token)
    {
        // Do something.
        concurrency::wait(2000);

        if (concurrency::is_task_cancellation_requested())
        {
            concurrency::cancel_current_task();
        }

        // Do something else.
        concurrency::wait(2000);

        return true;
    });
}

然后，在您的 C# Windows 应用商店应用程序中创建两个按钮:

<Button x:Name="DoButton" Click="DoButton_Click">Do</Button>
<Button x:Name="CancelButton" Click="CancelButton_Click">Cancel</Button>

在 Do 按钮中调用组件的异步方法。

private System.Threading.CancellationTokenSource cts;

private async void DoButton_Click(object sender, RoutedEventArgs e)
{
    cts = new System.Threading.CancellationTokenSource();
    var class1 = new MyClass();
    try
    {
        var asyncOp = await class1.DoSomeTaskAsync().AsTask(cts.Token);
        System.Diagnostics.Debug.WriteLine(asyncOp);
    }
    catch (OperationCanceledException oce)
    {
        // I want to get here.
        System.Diagnostics.Debug.WriteLine(oce);
    }
}

并在取消按钮中取消操作。

private void CancelButton_Click(object sender, RoutedEventArgs e)
{
    cts.Cancel();
    cts = null;
}

运行应用程序，点击Do 按钮，然后在两秒内点击Cancel 按钮。您应该得到一个 System.Threading.OperationCanceledException。