apollo::cyber::TaskManager类 参考

#include <task_manager.h>

apollo::cyber::TaskManager 的协作图:

Public 成员函数
virtual	~TaskManager ()
void	Shutdown ()
template<typename F , typename... Args>
auto	Enqueue (F &&func, Args &&... args) -> std::future< typename std::result_of< F(Args...)>::type >

详细描述

在文件 task_manager.h 第 34 行定义.

构造及析构函数说明

~TaskManager()

apollo::cyber::TaskManager::~TaskManager ( )

virtual

在文件 task_manager.cc 第 61 行定义.

{ Shutdown(); }

成员函数说明

Enqueue()

template<typename F , typename... Args>

auto apollo::cyber::TaskManager::Enqueue ( F &&  func, Args &&...  args  ) -> std::future<typename std::result_of<F(Args...)>::type>

inline

在文件 task_manager.h 第 41 行定义.

                                                          {
    using return_type = typename std::result_of<F(Args...)>::type;
    auto task = std::make_shared<std::packaged_task<return_type()>>(
        std::bind(std::forward<F>(func), std::forward<Args>(args)...));
    if (!stop_.load()) {
      task_queue_->Enqueue([task]() { (*task)(); });
      for (auto& task : tasks_) {
        scheduler::Instance()->NotifyTask(task);
      }
    }
    std::future<return_type> res(task->get_future());
    return res;
  }

Shutdown()

void apollo::cyber::TaskManager::Shutdown

(

)

在文件 task_manager.cc 第 63 行定义.

                           {
  if (stop_.exchange(true)) {
    return;
  }
  for (uint32_t i = 0; i < num_threads_; i++) {
    scheduler::Instance()->RemoveTask(task_prefix + std::to_string(i));
  }
}

---

该类的文档由以下文件生成:

• cyber/task/task_manager.h
• cyber/task/task_manager.cc