| 17 | } |
| 18 | |
| 19 | void OrderExecutor::stop() { |
| 20 | running_ = false; |
| 21 | cv_.notify_one(); |
| 22 | |
| 23 | if (execution_thread_.joinable()) { |
| 24 | execution_thread_.join(); |
| 25 | } |
| 26 | spdlog::info("Order executor stopped"); |
| 27 | } |
| 28 | |
| 29 | void OrderExecutor::submitOrder(std::shared_ptr<Order> order) { |
| 30 | { |