Method AddTask

src/colmap/util/threading.h:368–391

template <class func_t, class... args_t>
auto ThreadPool::AddTask(func_t&& f, args_t&&... args)
    -> std::shared_future<result_of_t<func_t, args_t...>> {
  using return_t = result_of_t<func_t, args_t...>;

  auto task = std::make_shared<std::packaged_task<return_t()>>(
      std::bind(std::forward<func_t>(f), std::forward<args_t>(args)...));

  std::shared_future<return_t> result = task->get_future().share();

  {
    std::unique_lock<std::mutex> lock(mutex_);
    if (stopped_) {
      throw std::runtime_error("Cannot add task to stopped thread pool.");
    }
    tasks_.emplace([task = std::move(task), result]() {
      (*task)();
      return [result = std::move(result)]() { result.get(); };
    });
  }

  task_condition_.notify_one();

  return result;
}

template <typename T>
JobQueue<T>::JobQueue() : JobQueue(std::numeric_limits<size_t>::max()) {}