Method scheduleTask

native/cpp/CommonCpp/Tools/WorkerThread.cpp:22–29

}

void WorkerThread::scheduleTask(const taskType task) {
  if (!this->tasks.try_push(std::make_unique<taskType>(std::move(task)))) {
    std::string errorMessage{
        "Error scheduling task on the " + this->name + " worker thread"};
    Logger::log(errorMessage);
    throw std::runtime_error(errorMessage);
  }
}

WorkerThread::~WorkerThread() {
  this->tasks.push(nullptr);