| 27 | } |
| 28 | |
| 29 | void OrderExecutor::submitOrder(std::shared_ptr<Order> order) { |
| 30 | { |
| 31 | std::lock_guard<std::mutex> lock(mutex_); |
| 32 | order_queue_.push(order); |
| 33 | } |
| 34 | cv_.notify_one(); |
| 35 | spdlog::info("Order submitted: {}", order->getOrderId()); |
| 36 | } |
| 37 | |
| 38 | void OrderExecutor::executionLoop() { |
| 39 | while (running_) { |
no test coverage detected