C#与C++的发展历程第三 - C#5.0异步编程巅峰 - hystar(17)_H5之家

下面的代码就是包装了最简单的过程代码：

IAsyncOperation<int>^ op2 = create_async([]() { return 0; });

也可以像上面说的包装一段create_task的代码（把C++内部的任务暴露给WinRT接口）：

IAsyncOperation<int>^ op3 = create_async([](){ return create_task(KnownFolders::DocumentsLibrary->GetFileAsync("Dictionary.txt")).then([](StorageFile^ file) { int wordNum = 0; // 获取单词数 return wordNum; }; });

通过create_async的重载也可以轻松的支持取消和进度报告。

扩展的C++使用的异步模式与C# TPL使用的标记式取消模型一致，但在使用上还是稍有不同，在介绍这种模式之前，先来说说取消延续的问题，如下面的代码：

auto t1 = create_task([]() -> int { //取消任务 cancel_current_task(); }); auto t2 = t1.then([](task<int> t) { try { int n = t.get(); wcout << L"后续任务" << endl; } catch (const task_canceled& e) { } }); auto t3 = t1.then([](int n) { wcout << L"后续任务" << endl; });

这个例子中可以看到，我们可以在task内部方法中通过cancel_current_task()调用来取消当前的任务。如果t1被手动取消，对于t1的两个后继任务t2和t3，t2会被取消，t3不会被取消。这是由于t2是基于值延续的延续，而t3是基于任务的延续。

接下来的示例展示了C++中的标记式取消：

cancellation_token_source cts; auto token = cts.get_token(); auto t = create_task([] { bool moreToDo = true; while (moreToDo) { //是不是的检查是否取消被设置 if (is_task_cancellation_requested()) { //取消任务 cancel_current_task(); } else { moreToDo = do_work(); } } }, token).then([]{ // 延续任务 },token,concurrency::task_continuation_context::use_current);//传递取消标记，接收取消标记的重载还需要延续上下文的参数 // 触发取消 cts.cancel(); t.wait();

通过使用cancellation_token，取消也可以传递到基于任务的延续。

上面演示的例子cancellation_token是在create_async方法内部定义的，更常见的情况在create_async的工作方法参数中显示声明cancellation_token并传入到工作方法内，这样IAsyncXXX上面的Cancel方法被调用，取消标志也会被自动设置，从而触发链式的标记性取消。

说起来很抽象，可以参考下面的代码：

IAsyncAction^ DoSomething(){ return create_async([](cancellation_token ct) { auto t = create_task([ct]() { // do something }); }); }

这样当DoSomething返回值（IAsyncAction对象）的Cancel方法被调用后，ct被标记为取消，任务t会在合适的时间被取消执行。

C++的cancellation_token有一个更高级的功能：其上可以设置回调函数，当cts触发取消时，token被标记为取消时，会执行这个回调函数的代码。

cancellation_token_registration cookie; cookie = token.register_callback([&e, token, &cookie]() { // 记录task被取消的日志等 // 还可以取消注册的回调 token.deregister_callback(cookie); });

说完取消，再来看一下进度报告。下面的例子基本是演示进度报告最简单的例子。

IAsyncOperationWithProgress<int, double>^ DoSometingWithProgressAsync(int input) { return create_async([this, input](progress_reporter<double> reporter) -> int { auto results = input; reporter.report(1); // do something reporter.report(50); // do something reporter.report(100.0); return results; }); }

我们将一个concurrency::progress_reporter<T>对象当作参数传入create_async接收的工作函数。然后就可以使用reporter的report方法来报告进度。返回的IAsyncOperationWithProgress类型可以使这个进度报告与WinRT中调用这个方法的代码协同工作。

2. 调用WinRT标准的异步方法