{"id":103217,"date":"2019-12-16T07:00:00","date_gmt":"2019-12-16T15:00:00","guid":{"rendered":"http:\/\/devblogs.microsoft.com\/oldnewthing\/?p=103217"},"modified":"2019-12-18T09:21:28","modified_gmt":"2019-12-18T17:21:28","slug":"20191216-00","status":"publish","type":"post","link":"https:\/\/devblogs.microsoft.com\/oldnewthing\/20191216-00\/?p=103217","title":{"rendered":"C++ coroutines: Short-circuiting suspension, part 2"},"content":{"rendered":"

There’s one last section of the outline of compiler code generation for co_await<\/code> that is marked “We’re not ready to talk about this step yet.” Let’s talk about that step.<\/p>\n

Before suspending the coroutine, the compiler asks the awaiter’s await_ready<\/code> method. This method returns true<\/code> if the operation is already complete, or false<\/code> if the coroutine should suspend.<\/p>\n

If the operation is already complete, then the compiler can avoid having to save the coroutine’s state, only to load it back up again immediately.<\/p>\n\n\n\n\n\n\n
 <\/td>\n\n
calculate x<\/code><\/div>\n
obtain awaiter<\/code><\/div>\n<\/td>\n<\/tr>\n
co_await<\/code><\/td>\n\n
if (!awaiter.await_ready())<\/code> \u21d0<\/span><\/div>\n
{<\/code><\/div>\n
save state for resumption<\/div>\n
if (awaiter.await_suspend(handle))<\/code><\/div>\n
{<\/code><\/div>\n
return to caller<\/div>\n<\/td>\n<\/tr>\n
\n
[Invoking the handle resumes execution here]<\/div>\n
}<\/code><\/div>\n
restore state after resumption<\/div>\n
}<\/code> \u21d0<\/span><\/div>\n
result = awaiter.await_resume();<\/code><\/div>\n<\/td>\n<\/tr>\n
 <\/td>\nexecution continues<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n

In the case where await_ready<\/code> says, “Yes, I’m ready!”, the compiler skips over the code that saves the coroutine state, creates a continuation handle, suspends the coroutine, and asks the await_<\/code>suspend<\/code> to arrange for the coroutine’s continuation; and then when the continuation occurs, restoring the coroutine state. Instead, it can go straight to the “So what was the result?” This avoids a bunch of register spilling and reloading.<\/p>\n

The C++ language comes with a predefined awaiter known as suspend_<\/code>never<\/code>. Its await_<\/code>ready<\/code> always returns true<\/code>, which means that it never actually suspends. It always goes straight to the continuation.\u00b9<\/p>\n

We can take advantage of the await_<\/code>ready<\/code> method resume_<\/code>in_<\/code>any_<\/code>apartment<\/code> function:<\/p>\n

template<typename Async,\r\n         typename = std::enable_if_t<\r\n             std::is_convertible_v<\r\n                 Async,\r\n                 winrt::Windows::Foundation::IAsyncInfo>>>\r\n[[nodiscard]] auto resume_in_any_apartment(Async async)\r\n{\r\n  struct awaiter\r\n  {\r\n    bool await_ready()\r\n    {\r\n      return async.Status() ==\r\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0  Windows::Foundation::AsyncStatus::Completed;\r\n    }<\/span>\r\n\r\n    void await_suspend(\r\n        std::experimental::coroutine_handle<> handle)\r\n    {\r\n      async.Completed([handler](auto&&...) { handler(); });\r\n    }\r\n\r\n    auto await_resume()\r\n    {\r\n        return async.GetResults();\r\n    }\r\n    Async async;\r\n  };\r\n  return awaiter{ std::move(async) };\r\n};\r\n<\/pre>\n
Perhaps a clearer example of this pattern is an awaitable which detects that its work is unnecessary, such as this one which switches to the dispatcher’s thread:<\/p>\n
auto ensure_dispatcher_thread(CoreDispatcher dispatcher)\r\n{\r\n  struct awaiter : std::experimental::suspend_always\r\n  {\r\n    CoreDispatcher dispatcher;\r\n\r\n    bool await_ready() { return dispatcher.HasThreadAccess(); }\r\n\r\n    void await_suspend(\r\n        std::experimental::coroutine_handle<> handle)\r\n    {\r\n      dispatcher.RunAsync(CoreDispatcherPriority::Normal,\r\n                           [handle]{ handle(); });\r\n    }\r\n  };\r\n  return awaiter{ {}, std::move(dispatcher) };\r\n}\r\n<\/pre>\n
This awaitable resumes execution on the dispatcher’s thread. In the await_<\/code>ready<\/code>, we check if we are already on the dispatcher’s thread. If so, then we report that the co_await<\/code> is complete even before it started, and execution will continue without ever suspending. Otherwise, the coroutine suspends, and we schedule its resumption on the dispatcher’s thread.<\/p>\n
\u00b9 An awaiter that never suspends sounds really strange. After all, why bother even being a coroutine! But it’s handy for cases in which you have to provide an awaiter even though nothing is being awaited. We’ll see examples of this when we study the promise object at some unspecified point in the future.<\/p>\n
 <\/p>\n","protected":false},"excerpt":{"rendered":"
Avoiding suspension entirely.<\/p>\n","protected":false},"author":1069,"featured_media":111744,"comment_status":"open","ping_status":"closed","sticky":false,"template":"","format":"standard","meta":{"_acf_changed":false,"footnotes":""},"categories":[1],"tags":[25],"class_list":["post-103217","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-oldnewthing","tag-code"],"acf":[],"blog_post_summary":"
Avoiding suspension entirely.<\/p>\n","_links":{"self":[{"href":"https:\/\/devblogs.microsoft.com\/oldnewthing\/wp-json\/wp\/v2\/posts\/103217","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/devblogs.microsoft.com\/oldnewthing\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/devblogs.microsoft.com\/oldnewthing\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/devblogs.microsoft.com\/oldnewthing\/wp-json\/wp\/v2\/users\/1069"}],"replies":[{"embeddable":true,"href":"https:\/\/devblogs.microsoft.com\/oldnewthing\/wp-json\/wp\/v2\/comments?post=103217"}],"version-history":[{"count":0,"href":"https:\/\/devblogs.microsoft.com\/oldnewthing\/wp-json\/wp\/v2\/posts\/103217\/revisions"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/devblogs.microsoft.com\/oldnewthing\/wp-json\/wp\/v2\/media\/111744"}],"wp:attachment":[{"href":"https:\/\/devblogs.microsoft.com\/oldnewthing\/wp-json\/wp\/v2\/media?parent=103217"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/devblogs.microsoft.com\/oldnewthing\/wp-json\/wp\/v2\/categories?post=103217"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/devblogs.microsoft.com\/oldnewthing\/wp-json\/wp\/v2\/tags?post=103217"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}