windows C++-高级并发和异步(三)

深入了解 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 信息检索取消标记。 可以针对该标记使用函数调用运算符以查询取消状态，实质上是轮询取消。 如果执行某项计算资源受限的操作，或循环访问大型集合，则这是一种合理的方法。