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

Change function names, and add #define for color

Browse Source
This commit is contained in:
mbandic 2024-09-06 08:56:08 +00:00
parent e3eddf006b
commit 0b94c1e86c
6 changed files with 109 additions and 83 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
README.md
View File

@ -27,9 +27,9 @@ The asynchronous filesystem is provided solely to guide users on how to wrap any
Just download the latest release and unzip it into your project.
```c++
#define NUM_OF_RUNNERS 8 // To change the number of threads used by atask, without this it runs according to the number of cores
#define NUM_OF_RUNNERS 8 // To change the number of threads used by asynco, without this it runs according to the number of cores
#include "asynco/lib/asynco.hpp" // atask(), wait()
#include "asynco/lib/asynco.hpp" // asynco(), wait()
#include "asynco/lib/triggers.hpp" // trigger (event emitter)
#include "asynco/lib/timers.hpp" // periodic, delayed (like setInterval and setTimeout from JS)
#include "asynco/lib/filesystem.hpp" // for async read and write files
@ -85,9 +85,9 @@ Make functions asynchronous
* Run an lambda function asynchronously
*/
atask( []() {
asynco( []() {
sleep_for(2s); // only for simulating long duration function
cout << "atask" << endl;
cout << "asynco" << endl;
return 5;
});
@ -100,7 +100,7 @@ void notLambdaFunction() {
cout << "Call to not lambda function" << endl;
}
atask (notLambdaFunction);
asynco (notLambdaFunction);
/**
* Run class method
@ -114,7 +114,7 @@ class clm {
};
clm classes;
atask( [&classes] () {
asynco( [&classes] () {
classes.classMethode();
});
@ -124,9 +124,9 @@ atask( [&classes] () {
* Wait after runned as async
*/
auto a = atask( []() {
auto a = asynco( []() {
sleep_for(2s); // only for simulating long duration function
cout << "atask" << endl;
cout << "asynco" << endl;
return 5;
});
@ -136,7 +136,7 @@ cout << wait(a) << endl;
* Wait async function call and use i cout
*/
cout << wait(atask( [] () {
cout << wait(asynco( [] () {
sleep_for(chrono::seconds(1)); // only for simulating long duration function
cout << "wait end" << endl;
return 4;

2
lib/asynco.hpp
View File

@ -59,7 +59,7 @@ class {
* Run the function asynchronously
*/
template<class F, class... Args>
auto atask(F&& f, Args&&... args) -> future<typename result_of<F(Args...)>::type> {
auto nonsync(F&& f, Args&&... args) -> future<typename result_of<F(Args...)>::type> {
using return_type = typename result_of<F(Args...)>::type;
future<return_type> res = _asynco_engine.io_context.post(boost::asio::use_future(bind(forward<F>(f), forward<Args>(args)...)));
return res;

19
lib/define.hpp Normal file
View File

@ -0,0 +1,19 @@
#ifndef _ASYNCO_DEFINE_
#define _ASYNCO_DEFINE_
namespace marcelb {
namespace asynco {
/**
* Alternative names of functions - mostly for the sake of more beautiful coloring of the code
*/
#define nonsync marcelb::asynco::nonsync
#define wait marcelb::asynco::wait
}
}
#endif

8
lib/filesystem.hpp
View File

@ -19,7 +19,7 @@ namespace fs {
*/
template<typename Callback>
void read(string path, Callback&& callback) {
atask( [&path, callback] () {
asynco::nonsync( [&path, callback] () {
string content;
try {
string line;
@ -48,7 +48,7 @@ void read(string path, Callback&& callback) {
* Asynchronous file reading
*/
future<string> read(string path) {
return atask( [&path] () {
return asynco::nonsync( [&path] () {
string content;
string line;
ifstream file (path);
@ -72,7 +72,7 @@ future<string> read(string path) {
*/
template<typename Callback>
void write(string path, string content, Callback&& callback) {
atask( [&path, &content, callback] () {
asynco::nonsync( [&path, &content, callback] () {
try {
ofstream file (path);
if (file.is_open()) {
@ -95,7 +95,7 @@ void write(string path, string content, Callback&& callback) {
* Asynchronous file writing with callback after write complete
*/
future<void> write(string path, string content) {
return atask( [&path, &content] () {
return asynco::nonsync( [&path, &content] () {
ofstream file (path);
if (file.is_open()) {
file << content;

2
lib/trigger.hpp
View File

@ -42,7 +42,7 @@ class trigger {
if (it_eve != triggers.end()) {
for (uint i =0; i<it_eve->second.size(); i++) {
auto callback = bind(it_eve->second[i], forward<Args>(args)...);
atask(callback);
asynco::nonsync(callback);
}
}
}

143
test/test.cpp
View File

@ -4,6 +4,7 @@
#include "../lib/trigger.hpp"
#include "../lib/filesystem.hpp"
#include "../lib/timers.hpp"
#include "../lib/define.hpp"
using namespace marcelb::asynco;
using namespace triggers;
@ -11,11 +12,13 @@ using namespace triggers;
#include <iostream>
#include <unistd.h>
#include <thread>
#include <future>
using namespace std;
using namespace this_thread;
void sleep_to (int _time) {
promise<void> _promise;
delayed t( [&]() {
@ -131,31 +134,35 @@ int main () {
// * Run an function asyncronic
// */
// atask( []() {
// sleep_for(2s); // only for simulate log duration function
// cout << "atask 1" << endl;
// return 5;
nonsync ( []() {
sleep_for(2s); // only for simulate log duration function
cout << "asynco 1" << endl;
return 5;
});
/**
* Call not lambda function
*/
nonsync (notLambdaFunction);
wait (
nonsync (
notLambdaFunction
)
);
// async(launch::async, [] () {
// cout << "Another thread in async style!" << endl;
// });
// /**
// * Call not lambda function
// */
// atask (notLambdaFunction);
// wait (
// atask (
// notLambdaFunction
// )
// );
// /**
// * Call class method
// */
// clm classes;
// atask( [&classes] () {
// asynco( [&classes] () {
// classes.classMethode();
// });
@ -165,20 +172,20 @@ int main () {
// * Wait after runned as async
// */
// auto a = atask( []() {
// auto a = asynco( []() {
// sleep_for(2s); // only for simulate log duration function
// cout << "atask 2" << endl;
// cout << "asynco 2" << endl;
// return 5;
// });
// cout << wait(a) << endl;
// cout << "print after atask 2" << endl;
// cout << "print after asynco 2" << endl;
// /**
// * Wait async function call and use i cout
// */
// cout << wait(atask( [] () {
// cout << wait(asynco( [] () {
// sleep_for(chrono::seconds(1)); // only for simulate log duration function
// cout << "wait end" << endl;
// return 4;
@ -209,9 +216,9 @@ int main () {
// */
// atask( [] {
// asynco( [] {
// cout << "idemo ..." << endl;
// atask( [] {
// asynco( [] {
// cout << "ugdnježdena async funkcija " << endl;
// });
// });
@ -222,68 +229,68 @@ int main () {
* initialization of typed events
*/
trigger<int, int> ev2int;
trigger<int, string> evintString;
trigger<> evoid;
// trigger<int, int> ev2int;
// trigger<int, string> evintString;
// trigger<> evoid;
ev2int.on("sum", [](int a, int b) {
cout << "Sum " << a+b << endl;
});
// ev2int.on("sum", [](int a, int b) {
// cout << "Sum " << a+b << endl;
// });
ev2int.on("sum", [](int a, int b) {
cout << "Sum done" << endl;
});
// ev2int.on("sum", [](int a, int b) {
// cout << "Sum done" << endl;
// });
evintString.on("substract", [](int a, string b) {
cout << "Substract " << a-stoi(b) << endl;
});
// evintString.on("substract", [](int a, string b) {
// cout << "Substract " << a-stoi(b) << endl;
// });
evoid.on("void", []() {
cout << "Void emited" << endl;
});
// evoid.on("void", []() {
// cout << "Void emited" << endl;
// });
string emited2 = "2";
// string emited2 = "2";
evoid.on("void", [&]() {
cout << "Void emited " << emited2 << endl;
});
// evoid.on("void", [&]() {
// cout << "Void emited " << emited2 << endl;
// });
evoid.tick("void");
sleep(1);
// evoid.tick("void");
// sleep(1);
/**
* Emit
*/
// /**
// * Emit
// */
ev2int.tick("sum", 5, 8);
// ev2int.tick("sum", 5, 8);
sleep(1);
evintString.tick("substract", 3, to_string(2));
// sleep(1);
// evintString.tick("substract", 3, to_string(2));
sleep(1);
evoid.off("void");
evoid.tick("void");
// sleep(1);
// evoid.off("void");
// evoid.tick("void");
cout << "Ukupno 2 int " << ev2int.listeners() << endl;
cout << "Ukupno evintString " << evintString.listeners() << endl;
cout << "Ukupno evoid " << evoid.listeners() << endl;
cout << "Ukupno 2 int " << ev2int.listeners("sum") << endl;
// cout << "Ukupno 2 int " << ev2int.listeners() << endl;
// cout << "Ukupno evintString " << evintString.listeners() << endl;
// cout << "Ukupno evoid " << evoid.listeners() << endl;
// cout << "Ukupno 2 int " << ev2int.listeners("sum") << endl;
/**
* Own class
*/
// /**
// * Own class
// */
myOwnClass myclass;
// myOwnClass myclass;
delayed t( [&] {
myclass.tick("constructed", 1);
}, 200);
// delayed t( [&] {
// myclass.tick("constructed", 1);
// }, 200);
myclass.on("constructed", [] (int i) {
cout << "Constructed " << i << endl;
});
// myclass.on("constructed", [] (int i) {
// cout << "Constructed " << i << endl;
// });