Method processQueue

devices/cpu/cpu_engine.cpp:192–231

  }

  void CPUEngine::processQueue()
  {
    for (; ;)
    {
      Task task;

      // Wait until a task is available in the queue
      {
        std::unique_lock<std::mutex> lock(queueMutex);
        queueCond.wait(lock, [&] { return !queue.empty() || queueShutdown; });
        if (queue.empty() && queueShutdown)
          return;
        task = std::move(queue.front());
      }

      // Execute queued tasks in the arena until the queue gets empty
      arena->execute([&]
      {
        for (; ;)
        {
          if (task.ct && task.ct->isCancelled())
            device->setAsyncError(Error::Cancelled, "execution was cancelled");
          else
            task.func();

          task = {};

          {
            std::lock_guard<std::mutex> lock(queueMutex);
            queue.pop();
            if (queue.empty())
              break;
            task = std::move(queue.front());
          }
        }

        queueCond.notify_all();
      });
    }
  }

OIDN_NAMESPACE_END