marcelb/asynco
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Await all on no-void return values

Browse Source
This commit is contained in:
mbandic 2025-03-31 12:22:38 +02:00
parent 1853318016
commit a1606fd3b6
2 changed files with 50 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
lib/asynco.hpp
View File

@ -35,6 +35,26 @@ T await_(future<T>&& r) {
return move(r).get();
}
/**
* Block until the multiple asynchronous call completes
* Use only on no-void calls
*/
template<typename... F>
auto await_(F&&... f) -> std::tuple<typename std::decay<decltype(f.get())>::type...> {
return std::make_tuple(move(f).get()...);
}
/**
* Block until the multiple asynchronous call completes
* Use only on no-void calls
*/
template<typename... F>
auto await_(F&... f) -> std::tuple<typename std::decay<decltype(f.get())>::type...> {
return std::make_tuple(f.get()...);
}
/**
* Block until the asynchronous call completes or time expired
*/

45
test/main.cpp
View File

@ -278,24 +278,39 @@ int main () {
// // -------------------------- AWAIT ALL ----------------------------------
// auto a = async_ ( []() {
// cout << "A" << endl;
// return 3;
// });
auto a = async_ ( []() {
cout << "A" << endl;
return 3;
});
// auto b = async_ ( []() {
// cout << "B" << endl;
// throw runtime_error("Test exception");
// return;
// });
auto b = async_ ( []() {
cout << "B" << endl;
// throw runtime_error("Test exception");
return;
});
// auto c = async_ ( []() {
// cout << "C" << endl;
// return "Hello";
// });
auto c = async_ ( []() {
cout << "C" << endl;
return "Hello";
});
// int a_;
// string c_;
int a_;
string c_;
// auto all = await_(a, c);
// cout << get<0>(all) << get<1>(all) << endl;
// ili
tie(a_, c_) = await_(a, c);
cout << a_ << c_ << endl;
int d_;
float e_;
tie(d_, e_) = await_( async_ ( []() {return 1;}), async_ ([](){ return 4.3;}));
cout << d_ << e_ << endl;
// auto await_all = [&] () {
// a_ = await_(a);