Method dispatchInternal

CesiumAsync/src/QueuedScheduler.cpp:92–110

}

bool QueuedScheduler::dispatchInternal(bool blockIfNoTasks) {
  async::task_run_handle t;

  {
    std::unique_lock<std::mutex> guard(this->_pImpl->mutex);
    t = this->_pImpl->queue.pop();
    if (blockIfNoTasks && !t) {
      this->_pImpl->conditionVariable.wait(guard);
    }
  }

  if (t) {
    auto scope = this->immediate.scope();
    t.run();
    return true;
  } else {
    return false;
  }
}

void QueuedScheduler::unblock() {
  std::unique_lock<std::mutex> guard(this->_pImpl->mutex);