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

Add example for await all

Browse Source
This commit is contained in:
mbandic 2024-09-26 07:23:33 +00:00
parent 7bf7a7d090
commit 2876372552
2 changed files with 129 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

54
README.md
View File

@ -142,6 +142,60 @@ cout << await_(async_ ( [] () {
return 4;
})) << endl;
/**
* Await all
**/
auto a = async_ ( []() {
cout << "A" << endl;
return 3;
});
auto b = async_ ( []() {
cout << "B" << endl;
throw runtime_error("Test exception");
return;
});
auto c = async_ ( []() {
cout << "C" << endl;
return "Hello";
});
int a_;
string c_;
auto await_all = [&] () {
a_ = await_(a);
await_(b);
c_ = await_(c);
};
try {
await_all();
cout << "a_ " << a_ << " c_ " << c_ << endl;
} catch (const exception& exc) {
cout << exc.what() << endl;
}
// // same type
vector<future<void>> fut_vec;
for (int i=0; i<5; i++) {
fut_vec.push_back(
async_ ( [i]() {
cout << "Async_ " << i << endl;
})
);
}
auto await_all = [&] () {
for (int i=0; i<fut_vec.size(); i++) {
await_ (fut_vec[i]);
}
};
/**
* Sleep with delayed sleep implement
*/

96
test/test.cpp
View File

@ -13,6 +13,7 @@ using namespace triggers;
#include <unistd.h>
#include <thread>
#include <future>
#include <vector>
using namespace std;
using namespace this_thread;
@ -134,24 +135,25 @@ int main () {
// * Run an function asyncronic
// */
async_ ( []() {
sleep_for(2s); // only for simulate log duration function
cout << "asynco 1" << endl;
return 5;
});
// async_ ( []() {
// sleep_for(2s); // only for simulate log duration function
// cout << "asynco 1" << endl;
// return 5;
// });
/**
* Call not lambda function
*/
// /**
// * Call not lambda function
// */
async_ (notLambdaFunction);
// async_ (notLambdaFunction);
await_ (
async_ (
notLambdaFunction
)
);
// await_ (
// async_ (
// notLambdaFunction
// )
// );
// async(launch::async, [] () {
// cout << "Another thread in async style!" << endl;
@ -162,7 +164,7 @@ int main () {
// */
// clm classes;
// asynco( [&classes] () {
// async_ ( [&classes] () {
// classes.classMethode();
// });
@ -172,20 +174,20 @@ int main () {
// * await_ after runned as async
// */
// auto a = asynco( []() {
// auto a = async_ ( []() {
// sleep_for(2s); // only for simulate log duration function
// cout << "asynco 2" << endl;
// cout << "async_ 2" << endl;
// return 5;
// });
// cout << await_(a) << endl;
// cout << "print after asynco 2" << endl;
// cout << "print after async_ 2" << endl;
// /**
// * await_ async function call and use i cout
// */
// cout << await_(asynco( [] () {
// cout << await_(async_ ( [] () {
// sleep_for(chrono::seconds(1)); // only for simulate log duration function
// cout << "await_ end" << endl;
// return 4;
@ -216,13 +218,65 @@ int main () {
// */
// asynco( [] {
// async_ ( [] {
// cout << "idemo ..." << endl;
// asynco( [] {
// async_ ( [] {
// cout << "ugdnježdena async funkcija " << endl;
// });
// });
// // -------------------------- AWAIT ALL ----------------------------------
// auto a = async_ ( []() {
// cout << "A" << endl;
// return 3;
// });
// auto b = async_ ( []() {
// cout << "B" << endl;
// throw runtime_error("Test exception");
// return;
// });
// auto c = async_ ( []() {
// cout << "C" << endl;
// return "Hello";
// });
// int a_;
// string c_;
// auto await_all = [&] () {
// a_ = await_(a);
// await_(b);
// c_ = await_(c);
// };
// try {
// await_all();
// cout << "a_ " << a_ << " c_ " << c_ << endl;
// } catch (const exception& exc) {
// cout << exc.what() << endl;
// }
// // // same type
// vector<future<void>> fut_vec;
// for (int i=0; i<5; i++) {
// fut_vec.push_back(
// async_ ( [i]() {
// cout << "Async_ " << i << endl;
// })
// );
// }
// auto await_all = [&] () {
// for (int i=0; i<fut_vec.size(); i++) {
// await_ (fut_vec[i]);
// }
// };
// --------------- EVENTS -------------------
/**