preparation for presentation

Author: nixiz

async-call-helper/main.cpp

@@ -7,22 +7,21 @@
 
 using namespace std::chrono_literals;
 
-int main()
+int main(int argc, const char*[])
 {
-#if 1
+ bool run_unsafe = argc == 1;
+ if (run_unsafe)
  {
  unsafe_service s(5);
  s.execute();
  std::this_thread::sleep_for(1s);
  }
- (void) getchar();
-#else
- do
+ else 
  {
  safe_service s(5);
  s.execute();
- std::this_thread::sleep_for(3s);
- } while(getchar() != 'q');
-#endif
+ std::this_thread::sleep_for(1s);
+ }
+ (void)getchar();
 return 0;
 }

async-call-helper/safe-service.cpp

@@ -12,6 +12,7 @@ safe_service::~safe_service() {
 }
 
 static inline void safe_response_cb(void* context, int out_param) {
+ std::cout << "safe_response_cb\n";
  auto srv_ptr = asyn_call_token::from_context<safe_service>(context);
  if (srv_ptr) {
  srv_ptr->response(out_param);
@@ -20,21 +21,38 @@ static inline void safe_response_cb(void* context, int out_param) {
  }
 }
 
-void safe_service::execute() {
- // c::long_async_function(get_context(), safe_response_cb, *param);
+void safe_service::execute_c_style() 
+{
+ c_long_async_function(get_context(), safe_response_cb, *param);
+}
 
- // auto context = get_context<int>([this](int o) {
- // std::cout << "received response from lambda " << *param << ": " << o << "\n";
- // });
- // c::long_async_function(context.context, context.callback, *param);
+void safe_service::execute_cpp_lambda() 
+{
+ auto context = get_context<int>([this](int o) {
+ std::cout << "received response from lambda " << *param << ": " << o << "\n";
+ });
+ c_long_async_function(context.context, context.callback, *param);
+}
 
+void safe_service::execute_cpp_bind() 
+{
  using namespace std::placeholders;
  auto context_bind = get_context<int>(std::bind(&safe_service::response, this, _1));
  c_long_async_function(context_bind.context, context_bind.callback, *param * 3);
-
- //cpp::long_async_function(context_bind, *param);
 }
 
 void safe_service::response(int out_param) {
+ std::cout << "response\n";
  std::cout << "received response. this->param: " << *param << "\n";
-}
+}
+
+void safe_service::execute() 
+{
+ constexpr const auto cb_type = cb_type_e::c_style;
+ switch (cb_type)
+ {
+ case cb_type_e::c_style: execute_c_style(); break;
+ case cb_type_e::cpp_bind: execute_cpp_bind(); break;
+ case cb_type_e::cpp_lambda: execute_cpp_lambda(); break;
+ }
+}

async-call-helper/safe-service.h

@@ -2,6 +2,12 @@
 #include <memory>
 #include "async-call-helper.hpp"
 
+enum class cb_type_e {
+ c_style,
+ cpp_lambda,
+ cpp_bind
+};
+
 class safe_service 
  : public async_call_helper<safe_service, multi_thread_usage>
 {
@@ -12,5 +18,8 @@ class safe_service
  void response(int out_param);
  void execute();
 private:
+ void execute_c_style();
+ void execute_cpp_lambda();
+ void execute_cpp_bind();
  std::unique_ptr<int> param;
 };

async-call-helper/unsafe-service.cpp

@@ -13,6 +13,7 @@ unsafe_service::~unsafe_service() {
 }
 
 static inline void response_cb(void* context, int out_param) {
+ std::cout << "response_cb\n";
  auto srv_ptr = static_cast<unsafe_service*>(context);
  srv_ptr->response(out_param);
 }
@@ -23,5 +24,6 @@ void unsafe_service::execute() {
 
 void unsafe_service::response(int out_param)
 {
+ std::cout << "response\n";
  std::cout << "received response. this->param: " << *param << "\n";
 }