{"id":213,"date":"2014-11-12T07:35:00","date_gmt":"2014-11-12T07:35:00","guid":{"rendered":"https:\/\/blogs.msdn.microsoft.com\/vcblog\/2014\/11\/12\/resumable-functions-in-c\/"},"modified":"2019-02-18T18:05:11","modified_gmt":"2019-02-18T18:05:11","slug":"resumable-functions-in-c","status":"publish","type":"post","link":"https:\/\/devblogs.microsoft.com\/cppblog\/resumable-functions-in-c\/","title":{"rendered":"Resumable functions in C++"},"content":{"rendered":"

Last year, in a CTP release, we had provided a glimpse<\/a> into resumable functions and await support in the Visual C++ compiler. In Visual Studio 2015 Preview we have gotten further along that journey and provided a more general purpose solution. This Preview release provides experimental implementation for a proposal called “Resumable functions<\/a>” for the ISO C++ Standard. This is still work in progress but we believe this is the right time to open up the discussion and seek design feedback. An excellent overview of the topic is already available through this CppCon video<\/a>. The slides from that presentation are also available here<\/a>.<\/p>\n

As of this preview, this feature only works for x64 targets. In order to use this experimental feature you will need to include some new headers (e.g. “<experimental\/resumable><\/span>“) in your source files as well as specify the switch “\/await” on the compiler command-line.<\/p>\n

This feature is built upon the concept of a coroutine which you might have encountered in other languages such as Python, Ruby etc. It is a generalized routine entity which supports operations like suspend and resume in addition to the traditional invoke and return operations. Very simply, it can be thought of as a method which, instead of returning to the caller, stops dead in the middle of processing and yields a value to the caller. The next time the coroutine is called, it resumes where it left off until it yields another value.<\/p>\n

Here are a few code examples to get you started with the key aspects of this feature:<\/p>\n

Asynchronous operations <\/strong><\/span><\/p>\n

The below code snippet shows how the code would look like for a function that waits for a long running operation like a computation or I\/O. Note the usage of the proposed ‘__await’ keyword meant to signify waiting for the result of an asynchronous operation.<\/p>\n

#include <future><\/span><\/span><\/span><\/p>\n

using namespace std; <\/span><\/span><\/span><\/span>
using namespace std::chrono; <\/span><\/span><\/span><\/span>
 
\/\/ this could be some long running computation or I\/O<\/span>
future<int> calculate_the_answer() <\/span><\/span><\/span><\/span>
{ <\/span>
    return async([] { <\/span><\/span><\/span>
        this_thread::sleep_for(1s); return 42; <\/span><\/span><\/span>
    }); <\/span>
} <\/span>
 
\/\/ Here is a resumable function<\/span>
future<void> coro() { <\/span><\/span><\/span><\/span>
    printf(“Started waiting… n”); <\/span><\/span><\/span>
    auto result = __await calculate_the_answer(); <\/span><\/span><\/span><\/span><\/span>
    printf(“got %d. n”, result); <\/span><\/span><\/span>
} <\/span>
 
int _tmain(int argc, _TCHAR* argv[]) <\/span><\/span><\/span><\/span><\/span><\/span><\/span><\/span><\/span><\/span><\/span><\/span>
{ <\/span>
    coro().get(); <\/span>
}<\/span><\/p>\n

Generator pattern <\/strong><\/span><\/p>\n

The below code snippet demonstrates the usage of the proposed ‘__yield_value’ keyword in the generator pattern where the generator coroutine is able to “yield” the values back to the calling function and can also be cancelled on demand.<\/p>\n

#include <iostream><\/span><\/span><\/span>
#include <experimental\/generator><\/span><\/span><\/span>
 
using namespace std::experimental; <\/span><\/span><\/span><\/span>
using namespace std; <\/span><\/span><\/span><\/span>
 
generator<int> fib() <\/span><\/span><\/span><\/span>
{ <\/span>
 &n\nbsp;  int a = 0; <\/span><\/span><\/span>
    int b = 1; <\/span><\/span><\/span>
    for (;;) { <\/span><\/span><\/span>
        __yield_value a; <\/span><\/span><\/span>
        auto next = a + b; <\/span><\/span><\/span>
        a = b; <\/span>
        b = next; <\/span>
    } <\/span>
} <\/span>
 
int _tmain(int argc, _TCHAR* argv[]) <\/span><\/span><\/span><\/span><\/span><\/span><\/span><\/span><\/span><\/span><\/span><\/span>
{ <\/span>
    for (v : fib()) { <\/span><\/span><\/span>
        if (v > 50) <\/span><\/span><\/span>
            break; <\/span><\/span><\/span>
        cout << v << endl; <\/span>
    } <\/span>
}<\/span> <\/span><\/p>\n

Reactive Streams <\/strong><\/span><\/p>\n

The below code pattern demonstrates the usage of the proposed ‘for __await’ keyword in a scenario where a coroutine (Ticks) produces an asynchronous stream of values and a function (Sum) consumes those values. The coroutine TimeStamp demonstrates the scenario where a coroutine consumes an incoming stream, process it and outputs it to whoever is waiting for it.<\/p>\n

\/\/As a consumer<\/span>
future<int> Sum(async_read_stream<int> & input) <\/span><\/span><\/span><\/span><\/span>
{ <\/span>
    int result = 0; <\/span><\/span><\/span>
    for __await<\/span><\/strong>(v : input)<\/span><\/span>
    { <\/span>
        result += v; <\/span>
    } <\/span>
    return result; <\/span><\/span><\/span>
} <\/span>
 
\/\/As a producer :<\/span>
async_generator<int> Ticks() <\/span><\/span><\/span>
{ <\/span>
    for (int tick = 0;; ++tick) <\/span><\/span><\/span><\/span><\/span>
    { <\/span>
        __yield_value tick; <\/span><\/span><\/span>
        __await sleep_for(1ms); <\/span>
    } <\/span>
} <\/span>
 
\/\/As a transformer : (adds a timestamp to every observed value)<\/span>
template<class T> <\/span><\/span><\/span><\/span>
async_generator<pair<T, system_clock::time_point>> <\/span>
Timestamp(async_read_stream<T> S) <\/span>
{ <\/span>
    for __await(v: S) <\/span><\/span><\/span><\/p>\n

__yield_value { v, system_clock::now() }; <\/span><\/p>\n

}<\/span> <\/span><\/p>\n

These are just some of the examples of this feature. We will continue our work in this area beyond this Preview release and hope to add more coverage, better user experience and in-built support for more high-level scenarios in upcoming releases. However, we hope you will like what you have seen so far, play with this feature, find novel uses for the base concepts and functionality. We look forward to hearing all your feedback.<\/p><\/p>\n","protected":false},"excerpt":{"rendered":"

Last year, in a CTP release, we had provided a glimpse into resumable functions and await support in the Visual C++ compiler. In Visual Studio 2015 Preview we have gotten further along that journey and provided a more general purpose solution. This Preview release provides experimental implementation for a proposal called “Resumable functions” for the […]<\/p>\n","protected":false},"author":263,"featured_media":35994,"comment_status":"open","ping_status":"closed","sticky":false,"template":"","format":"standard","meta":{"_acf_changed":false,"footnotes":""},"categories":[1],"tags":[8],"class_list":["post-213","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-cplusplus","tag-announcement"],"acf":[],"blog_post_summary":"

Last year, in a CTP release, we had provided a glimpse into resumable functions and await support in the Visual C++ compiler. In Visual Studio 2015 Preview we have gotten further along that journey and provided a more general purpose solution. This Preview release provides experimental implementation for a proposal called “Resumable functions” for the […]<\/p>\n","_links":{"self":[{"href":"https:\/\/devblogs.microsoft.com\/cppblog\/wp-json\/wp\/v2\/posts\/213","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/devblogs.microsoft.com\/cppblog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/devblogs.microsoft.com\/cppblog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/devblogs.microsoft.com\/cppblog\/wp-json\/wp\/v2\/users\/263"}],"replies":[{"embeddable":true,"href":"https:\/\/devblogs.microsoft.com\/cppblog\/wp-json\/wp\/v2\/comments?post=213"}],"version-history":[{"count":0,"href":"https:\/\/devblogs.microsoft.com\/cppblog\/wp-json\/wp\/v2\/posts\/213\/revisions"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/devblogs.microsoft.com\/cppblog\/wp-json\/wp\/v2\/media\/35994"}],"wp:attachment":[{"href":"https:\/\/devblogs.microsoft.com\/cppblog\/wp-json\/wp\/v2\/media?parent=213"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/devblogs.microsoft.com\/cppblog\/wp-json\/wp\/v2\/categories?post=213"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/devblogs.microsoft.com\/cppblog\/wp-json\/wp\/v2\/tags?post=213"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}