| 134 | |
| 135 | |
| 136 | void SingleThreadedSchedulerClient::MaybeScheduleProcessQueue() |
| 137 | { |
| 138 | { |
| 139 | LOCK(m_callbacks_mutex); |
| 140 | // Try to avoid scheduling too many copies here, but if we |
| 141 | // accidentally have two ProcessQueue's scheduled at once its |
| 142 | // not a big deal. |
| 143 | if (m_are_callbacks_running) return; |
| 144 | if (m_callbacks_pending.empty()) return; |
| 145 | } |
| 146 | m_pscheduler->schedule(std::bind(&SingleThreadedSchedulerClient::ProcessQueue, this), std::chrono::system_clock::now()); |
| 147 | } |
| 148 | |
| 149 | void SingleThreadedSchedulerClient::ProcessQueue() |
| 150 | { |
no test coverage detected