| 147 | |
| 148 | |
| 149 | void SingleThreadedSchedulerClient::MaybeScheduleProcessQueue() { |
| 150 | { |
| 151 | LOCK(m_cs_callbacks_pending); |
| 152 | // Try to avoid scheduling too many copies here, but if we |
| 153 | // accidentally have two ProcessQueue's scheduled at once its |
| 154 | // not a big deal. |
| 155 | if (m_are_callbacks_running) return; |
| 156 | if (m_callbacks_pending.empty()) return; |
| 157 | } |
| 158 | m_pscheduler->schedule(std::bind(&SingleThreadedSchedulerClient::ProcessQueue, this)); |
| 159 | } |
| 160 | |
| 161 | void SingleThreadedSchedulerClient::ProcessQueue() { |
| 162 | std::function<void (void)> callback; |
no test coverage detected