飞凌嵌入式旗下教育品牌ElfBoard亮相全国大学生嵌入式竞赛总决赛现场-CFANZ编程社区

深入了解 winrt::resume_foreground(下)

调用 winrt::resume_foreground 时会始终先排队，然后展开堆栈。也可选择设置恢复优先级。

winrt::fire_and_forget RunAsync(DispatcherQueue queue)
{
    ...
 
    co_await winrt::resume_foreground(queue, DispatcherQueuePriority::High);
 
    ...
}

或者，使用默认的排队顺序。

...
#include <winrt/Windows.System.h>
using namespace Windows::System;
...
winrt::fire_and_forget RunAsync(DispatcherQueue queue)
{
    ...
 
    co_await queue;
 
    ...
}

如上所示，请确保包含要 co_await 的类型的命名空间的投影标头。例如 Windows::UI::Core::CoreDispatcher、Windows::System::DispatcherQueue 或 Microsoft::UI::Dispatching::DispatcherQueue。

或者，检测队列关闭情况并对其进行适当处理，如以下示例所示。

winrt::fire_and_forget RunAsync(DispatcherQueue queue)
{
    ...
 
    if (co_await queue)
    {
        ... // Resume on dispatcher thread.
    }
    else
    {
        ... // Still on calling thread.
    }
}

co_await 表达式返回 true，表明会在调度程序线程上进行恢复。换而言之，该排队操作是成功的。与之相反的是返回 false，这表明执行仍保留在调用线程上，因为队列的控制器关闭，再也不能处理队列请求。

因此，在将 C++/WinRT 与协同程序配合使用的情况下，尤其是在进行一些传统的 Petzold 样式桌面应用程序开发的情况下，你拥有很大的控制权限。

取消异步操作和取消回调

使用 Windows 运行时的异步编程功能可以取消正在进行的异步操作或运算。以下示例调用 StorageFolder::GetFilesAsync 来检索可能较大的文件集合，并将生成的异步操作对象存储在数据成员中。用户可以选择取消该操作。

// MainPage.xaml
...
<Button x:Name="workButton" Click="OnWork">Work</Button>
<Button x:Name="cancelButton" Click="OnCancel">Cancel</Button>
...

// MainPage.h
...
#include <winrt/Windows.Foundation.h>
#include <winrt/Windows.Foundation.Collections.h>
#include <winrt/Windows.Storage.Search.h>

using namespace winrt;
using namespace Windows::Foundation;
using namespace Windows::Foundation::Collections;
using namespace Windows::Storage;
using namespace Windows::Storage::Search;
using namespace Windows::UI::Xaml;
...
struct MainPage : MainPageT<MainPage>
{
    MainPage()
    {
        InitializeComponent();
    }

    IAsyncAction OnWork(IInspectable /* sender */, RoutedEventArgs /* args */)
    {
        workButton().Content(winrt::box_value(L"Working..."));

        // Enable the Pictures Library capability in the app manifest file.
        StorageFolder picturesLibrary{ KnownFolders::PicturesLibrary() };

        m_async = picturesLibrary.GetFilesAsync(CommonFileQuery::OrderByDate, 0, 1000);

        IVectorView<StorageFile> filesInFolder{ co_await m_async };

        workButton().Content(box_value(L"Done!"));

        // Process the files in some way.
    }

    void OnCancel(IInspectable const& /* sender */, RoutedEventArgs const& /* args */)
    {
        if (m_async.Status() != AsyncStatus::Completed)
        {
            m_async.Cancel();
            workButton().Content(winrt::box_value(L"Canceled"));
        }
    }

private:
    IAsyncOperation<::IVectorView<StorageFile>> m_async;
};
...

让我们通过一个简单的示例开始了解取消的实现端。

// main.cpp
#include <iostream>
#include <winrt/Windows.Foundation.h>

using namespace winrt;
using namespace Windows::Foundation;
using namespace std::chrono_literals;

IAsyncAction ImplicitCancelationAsync()
{
    while (true)
    {
        std::cout << "ImplicitCancelationAsync: do some work for 1 second" << std::endl;
        co_await 1s;
    }
}

IAsyncAction MainCoroutineAsync()
{
    auto implicit_cancelation{ ImplicitCancelationAsync() };
    co_await 3s;
    implicit_cancelation.Cancel();
}

int main()
{
    winrt::init_apartment();
    MainCoroutineAsync().get();
}

如果运行上述示例，则你会看到，ImplicitCancellationAsync 在三秒钟内每秒输出一条消息，然后，它会由于执行了取消操作而自动终止。之所以此行为是可行的，是因为在遇到 co_await 表达式时，协同例程会检查它是否已取消。如果已取消，则它会短路掉，否则它会像正常情况下一样暂停。

当然，取消也可以在协同例程暂停时发生。仅当协同例程恢复或者遇到另一个 co_await 时，它才会检查取消状态。问题在于，在响应取消时可能会出现过于粗糙粒度的延迟。

因此，另一种做法是从协同例程内部显式轮询取消。使用以下列表中的代码更新上述示例。在此新示例中，ExplicitCancelationAsync 检索 winrt::get_cancellation_token 函数返回的对象，并使用该对象定期检查是否已取消协同例程。只要尚未取消，协同例程就会无限循环；一旦取消，循环和函数就会正常退出。结果与前一个示例相同，不过，在此示例中，退出是显式发生的并且受控。

IAsyncAction ExplicitCancelationAsync()
{
    auto cancelation_token{ co_await winrt::get_cancellation_token() };

    while (!cancelation_token())
    {
        std::cout << "ExplicitCancelationAsync: do some work for 1 second" << std::endl;
        co_await 1s;
    }
}

IAsyncAction MainCoroutineAsync()
{
    auto explicit_cancelation{ ExplicitCancelationAsync() };
    co_await 3s;
    explicit_cancelation.Cancel();
}
...

等待 winrt::get_cancellation_token 时会使用协同例程代表你生成的 IAsyncAction 信息检索取消标记。可以针对该标记使用函数调用运算符以查询取消状态，实质上是轮询取消。如果执行某项计算资源受限的操作，或循环访问大型集合，则这是一种合理的方法。