Replace custom exit waiter with UserExitOnSignalWaiter

- Removed manual exit signal implementation using promise/future
- Added new `aos/exit_waiter/user_exit_on_signal/waiter.h` include
- Replaced custom wait logic with `UserExitOnSignalWaiter` class
- Cleaned up commented-out old implementation
- Maintained same functionality with cleaner interface

Author: linoxoidunix

aos/aos.h

@@ -31,6 +31,9 @@
 #include "aos/executer_provider/i_executor_provider.h"
 #include "aos/executor_strategy/executor_strategy.h"
 #include "aos/executor_strategy/i_executor_strategy.h"
+#include "aos/exit_waiter/i_exit_waiter.h"
+#include "aos/exit_waiter/user_exit_on_signal/waiter.h"
+#include "aos/exit_waiter/user_exit_on_timeout/waiter.h"
 #include "aos/hash_utils/decompose_hash.h"
 #include "aos/histogram/histogram_calculator.h"
 #include "aos/histogram/i_histogram_calculator.h"

aos/exit_waiter/i_exit_waiter.h

@@ -0,0 +1,13 @@
+#pragma once
+
+namespace aos {
+struct IExitWaiterInterface {
+    virtual void Wait()             = 0;
+    virtual ~IExitWaiterInterface() = default;
+};
+struct IAsyncExitWaiterInterface {
+    virtual boost::asio::awaitable<void> WaitAsync() = 0;
+    virtual ~IAsyncExitWaiterInterface()             = default;
+};
+
+}  // namespace aos

aos/exit_waiter/user_exit_on_signal/waiter.h

@@ -0,0 +1,34 @@
+#pragma once
+#include <atomic>
+#include <csignal>
+#include <future>
+
+#include "aos/exit_waiter/i_exit_waiter.h"
+#include "aos/logger/mylog.h"
+#include "boost/asio/io_context.hpp"
+#include "boost/asio/signal_set.hpp"
+#include "boost/asio/this_coro.hpp"
+
+namespace aos {
+namespace impl {
+class UserExitOnSignalWaiter : public IExitWaiterInterface {
+  public:
+    explicit UserExitOnSignalWaiter(boost::asio::thread_pool& pool)
+        : signal_set_(pool.get_executor(), SIGINT, SIGTERM) {}
+
+    void Wait() override {
+        std::promise<void> promise;
+        auto future = promise.get_future();
+
+        signal_set_.async_wait([&](const boost::system::error_code&,
+                                   int signal_number) { promise.set_value(); });
+
+        future.wait();  // блокируемся здесь
+    }
+
+  private:
+    boost::asio::signal_set signal_set_;
+};
+
+};  // namespace impl
+};  // namespace aos

aos/exit_waiter/user_exit_on_timeout/waiter.h

@@ -0,0 +1,41 @@
+#pragma once
+#include <atomic>
+#include <future>
+#include <csignal>
+
+#include "aos/exit_waiter/i_exit_waiter.h"
+#include "boost/asio/io_context.hpp"
+#include "boost/asio/signal_set.hpp"
+#include "boost/asio/this_coro.hpp"
+#include "aos/logger/my_logger.h"
+
+namespace aos {
+namespace impl {
+class UserExitOnTimeoutWaiter : public IExitWaiterInterface {
+public:
+    UserExitOnTimeoutWaiter(boost::asio::thread_pool& pool,
+                            std::chrono::steady_clock::duration timeout)
+        : timer_(pool.get_executor(), timeout) {}
+
+    void Wait() override {
+        std::promise<void> promise;
+        auto future = promise.get_future();
+
+        timer_.async_wait([&](const boost::system::error_code& ec) {
+            if (!ec) {
+                logi("Timeout reached");
+            } else {
+                loge("Timer error: {}", ec.message());
+            }
+            promise.set_value();
+        });
+
+        future.wait();  // блокируемся здесь
+    }
+
+private:
+    boost::asio::steady_timer timer_;
+};
+
+}  // namespace impl
+}  // namespace aos

examples/example47/main.cpp

@@ -16,6 +16,7 @@
 #include "aos/strategy_engine/i_strategy_engine.h"
 #include "aos/strategy_engine/strategy_engine.h"
 #include "aos/trading_pair/trading_pair.h"
+#include "aos/exit_waiter/user_exit_on_signal/waiter.h"
 
 namespace str {
 struct Config {
@@ -128,26 +129,39 @@ class StrategyWrapper {
 };
 };  // namespace str
 
-void wait_for_user_input(std::promise<void>& exit_signal) {
-    std::cout << "Press ENTER to exit...\n";
-    std::cin.get();           // ждём нажатия Enter
-    exit_signal.set_value();  // снимаем блокировку
-}
+// class UserExitWaiter {
+//   public:
+//     explicit UserExitWaiter(boost::asio::thread_pool& pool)
+//         : exit_future_(exit_promise_.get_future()) {
+//         boost::asio::post(pool, [this] {
+//             std::cout << "Press ENTER to exit...\n";
+//             std::cin.get();
+//             exit_promise_.set_value();
+//         });
+//     }
+
+//     void Wait() { exit_future_.wait(); }
+
+//   private:
+//     std::promise<void> exit_promise_;
+//     std::future<void> exit_future_;
+// };
 
 int main(int, char**) {
     {
         try {
             boost::asio::thread_pool thread_pool;
+            aos::impl::UserExitOnSignalWaiter user_waiter(thread_pool);
             using HashT = uint64_t;
             using Price = double;
             fmtlog::setLogLevel(fmtlog::LogLevel::DBG);
             // --- механизм блокировки через future ---
-            std::promise<void> exit_promise;
-            std::future<void> exit_future = exit_promise.get_future();
+            // std::promise<void> exit_promise;
+            // std::future<void> exit_future = exit_promise.get_future();
 
             // Поток, ожидающий пользовательский ввод
-            std::jthread input_thread(wait_for_user_input,
-                                      std::ref(exit_promise));
+            // std::jthread input_thread(wait_for_user_input,
+            //                          std::ref(exit_promise));
             // boost::asio::thread_pool thread_pool;
             LogPolling log_polling(thread_pool, std::chrono::microseconds(1));
             using Price = double;
@@ -190,7 +204,8 @@ int main(int, char**) {
                 aos::TradingPair::kETHUSDT);
 
             binance_futures_main_net_infrastructure->StartAsync();
-            exit_future.get();  // блокирующий вызов — будет ждать ENTER
+            // exit_future.get();  // блокирующий вызов — будет ждать ENTER
+            user_waiter.Wait();
             binance_futures_main_net_infrastructure->StopAsync();
         } catch (...) {
             loge("error occured");