to pause the video stream during the talk. 23 REVIEW C++ COROUTINE IN 10 MINS • Core concepts: promise object, coroutine handle • Keywords: co_return, co_await, co_yield(not covered here) • awaitables https://lewissbaker.github.io/2018/09/05/understanding -the-promise-type • User defined type(s) that stores whatever you want/required Promise Object Coroutine Handle • Literally a handle • Two different coroutine_handle<>, coroutine_handle<Promise> • coroutine_handle<>: resume/destroy coroutine, check status(done) • coroutine_handle<Promise>: provide access to the promise object(promise) Useful to know For convenience:

Non-blocking! writer.Close(); thread x thread yfutures/promises: “buffered channel” Promise promise; Channel::Reader reader = channel.Reader(); reader.Read(); // Blocks! Non-blocking! writer.Close(); thread x thread yfutures/promises: “buffered channel” Promise promise; Channel::Reader reader = channel.Reader(); reader.Read(); // Blocks! Close(); thread x thread yfutures/promises: “buffered channel” Promise promise; Future future = promise.Future(); reader.Read(); // Blocks! Channel::Writer writer

} }8/55 The coroutine promise promise type9/55 Cheat Sheet - Promise Type 1 struct ReturnType / std:: coroutine_traits < ReturnType , ...> { 2 struct promise_type { 3 promise_type (T...); // opt. 4 Awaitable 1 struct Awaitable { 2 bool await_ready (); 3 auto await_suspend (std:: coroutine_handle < promise_type >); 4 auto await_resume (); 5 };12/55 Cheat Sheet: Map of Coroutine Land13/55 Get the cheat Async { struct promise_type { /* ... */ }; };34/55 Setting up the Async object template struct Async { struct promise_type { /* ... */ }; std:: coroutine_handle <promise_type > self ;

Coroutines in VGJS – Example void test() { Coro retObj = driver(13); schedule(retObj); //put promise into a VGJS queue, a thread will grab it in its loop if(retObj.ready()) std::cout << "Result " << Coro retObj = driver(13); schedule(retObj); } Coro_promise Coro_promise VGJS Coroutines Coro driver(int i) { co_await promise.initial_suspend(); try { Coro retObj = coroTest(i); coroTest(i); int res = co_await retObj; co_return 0.0f; } catch (...) { promise.unhandled_exception(); } FinalSuspend: co_await promise.final_suspend(); } Coro coroTest(int i) { co_await thread_index_t{

est('GET', 'http://httpbin.org'); $promise = $client->sendAsync($request)->then(function ($response) { echo 'I completed! ' . $response->getBody(); }); $promise->wait(); User Guide Overview Requirements a Psr7\Http\Message\RequestInterface and array of transfer options, and must return a GuzzleHttp\Promise\PromiseInterface that is fulfilled with a Psr7\Http\Message\ResponseInterface on success. ... (mixed) client: $promise = $client->getAsync('http://httpbin.org/get'); $promise = $client->deleteAsync('http://httpbin.org/delete'); $promise = $client->headAsync('http://httpbin.org/get'); $promise = $clien

est('GET', 'http://httpbin.org'); $promise = $client->sendAsync($request)->then(function ($response) { echo 'I completed! ' . $response->getBody(); }); $promise->wait(); User Guide Overview Requirements a Psr7\Http\Message\RequestInterface and array of transfer options, and must return a GuzzleHttp\Promise\PromiseInterface that is fulfilled with a Psr7\Http\Message\ResponseInterface on success. ... (mixed) client: $promise = $client->getAsync('http://httpbin.org/get'); $promise = $client->deleteAsync('http://httpbin.org/delete'); $promise = $client->headAsync('http://httpbin.org/get'); $promise = $clien

\GuzzleHttp\Psr7\Request('GET', 'http://httpbin.org'); $promise = $client->sendAsync($request)->then(function ($response) { echo 'I completed! ' . $response->getBody(); }); $promise->wait(); Contents 1 Guzzle, Release a Psr7\Http\Message\RequestInterface and array of transfer options, and must return a GuzzleHttp\Promise\PromiseInterface that is fulfilled with a Psr7\Http\Message\ResponseInterface on success. ... (mixed) client: $promise = $client->getAsync('http://httpbin.org/get'); $promise = $client->deleteAsync('http://httpbin.org/delete'); $promise = $client->headAsync('http://httpbin.org/get'); $promise = $clien

.hpp:220 frame #3 : 0x0000555555571da5 in unifex::_ch::continuation_handlepromise<(anonymous namespace)::word_stats, false>::type>::resume() () at /home/cppcon/cppcon24-async-d () at /hom frame #3 : 0x0000555555571da5 in unifex::_ch::continuation_handlepromise<(a frame #4 : 0x0000555555579f86 in unifex::_task::_sr_thunk_task<(anonymous namespace)::word_s unifex::_seq::_sndrpromise::type:: frame #13: 0x000055555557dc9c in unifex::_await::_sender_task

0 码力 | 131 页 | 907.41 KB | 5 月前

3

\GuzzleHttp\Psr7\Request('GET', 'http://httpbin.org'); $promise = $client->sendAsync($request)->then(function ($response) { echo 'I completed! ' . $response->getBody(); }); $promise->wait(); Contents 1 Guzzle, Release a Psr7\Http\Message\RequestInterface and array of transfer options, and must return a GuzzleHttp\Promise\PromiseInterface that is fulfilled with a Psr7\Http\Message\ResponseInterface on success. ... (mixed) client: $promise = $client->getAsync('http://httpbin.org/get'); $promise = $client->deleteAsync('http://httpbin.org/delete'); $promise = $client->headAsync('http://httpbin.org/get'); $promise = $clien

\GuzzleHttp\Psr7\Request('GET', 'http://httpbin.org'); $promise = $client->sendAsync($request)->then(function ($response) { echo 'I completed! ' . $response->getBody(); }); $promise->wait(); Contents 1 Guzzle, Release a Psr7\Http\Message\RequestInterface and array of transfer options, and must return a GuzzleHttp\Promise\PromiseInterface that is fulfilled with a Psr7\Http\Message\ResponseInterface on success. handler client: $promise = $client->getAsync('http://httpbin.org/get'); $promise = $client->deleteAsync('http://httpbin.org/delete'); $promise = $client->headAsync('http://httpbin.org/get'); $promise = $clien