Changeset View
Changeset View
Standalone View
Standalone View
src/scheduler.cpp
Show First 20 Lines • Show All 191 Lines • ▼ Show 20 Lines | void SingleThreadedSchedulerClient::EmptyQueue() { | ||||
assert(!m_pscheduler->AreThreadsServicingQueue()); | assert(!m_pscheduler->AreThreadsServicingQueue()); | ||||
bool should_continue = true; | bool should_continue = true; | ||||
while (should_continue) { | while (should_continue) { | ||||
ProcessQueue(); | ProcessQueue(); | ||||
LOCK(m_cs_callbacks_pending); | LOCK(m_cs_callbacks_pending); | ||||
should_continue = !m_callbacks_pending.empty(); | should_continue = !m_callbacks_pending.empty(); | ||||
} | } | ||||
} | } | ||||
size_t SingleThreadedSchedulerClient::CallbacksPending() { | |||||
LOCK(m_cs_callbacks_pending); | |||||
return m_callbacks_pending.size(); | |||||
} |