| 188 | } |
| 189 | |
| 190 | void SingleThreadedSchedulerClient::AddToProcessQueue(std::function<void (void)> func) { |
| 191 | assert(m_pscheduler); |
| 192 | |
| 193 | { |
| 194 | LOCK(m_cs_callbacks_pending); |
| 195 | m_callbacks_pending.emplace_back(std::move(func)); |
| 196 | } |
| 197 | MaybeScheduleProcessQueue(); |
| 198 | } |
| 199 | |
| 200 | void SingleThreadedSchedulerClient::EmptyQueue() { |
| 201 | assert(!m_pscheduler->AreThreadsServicingQueue()); |
no outgoing calls