#include <prediction_thread_pool.h>

类 apollo::prediction::BaseThreadPool 继承关系图:

apollo::prediction::BaseThreadPool 的协作图:

Public 成员函数
	BaseThreadPool (int thread_num, int next_thread_pool_level)

void	Stop ()

	~BaseThreadPool ()

template<typename InputIter , typename F >
void	ForEach (InputIter begin, InputIter end, F f)

template<typename FuncType >
std::future< typename std::result_of< FuncType()>::type >	Post (FuncType &&func)

静态 Public 属性
static std::vector< int >	THREAD_POOL_CAPACITY = {20, 20, 20}

详细描述

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

构造及析构函数说明

◆ BaseThreadPool()

apollo::prediction::BaseThreadPool::BaseThreadPool	(	int	thread_num,
		int	next_thread_pool_level
	)

在文件 prediction_thread_pool.cc 第 25 行定义.

    : stopped_(false) {
  if (!task_queue_.Init(thread_num,
                        new apollo::cyber::base::BlockWaitStrategy())) {
    throw std::runtime_error("Task queue init failed.");
  }
  for (int i = 0; i < thread_num; ++i) {
    workers_.emplace_back([this, next_thread_pool_level, i] {
      PredictionThreadPool::s_thread_pool_level = next_thread_pool_level;
      while (!stopped_) {
        std::function<void()> task;
        if (task_queue_.WaitDequeue(&task)) {
          task();
        }
      }
    });
  }
}

◆ ~BaseThreadPool()

apollo::prediction::BaseThreadPool::~BaseThreadPool ( )

在文件 prediction_thread_pool.cc 第 52 行定义.

                                {
  if (stopped_.exchange(true)) {
    return;
  }
  task_queue_.BreakAllWait();
  for (std::thread& worker : workers_) {
    worker.join();
  }
}

成员函数说明

◆ ForEach()

template<typename InputIter , typename F >

void apollo::prediction::BaseThreadPool::ForEach	(	InputIter	begin,
		InputIter	end,
		F	f
	)

inline

在文件 prediction_thread_pool.h 第 43 行定义.

                                                    {
    std::vector<std::future<void>> futures;
    for (auto iter = begin; iter != end; ++iter) {
      auto& elem = *iter;
      futures.emplace_back(this->Post([&] { f(elem); }));
    }
    for (auto& future : futures) {
      if (future.valid()) {
        future.get();
      } else {
        AERROR << "Future is invalid.";
      }
    }
  }

◆ Post()

template<typename FuncType >

std::future< typename std::result_of< FuncType()>::type > apollo::prediction::BaseThreadPool::Post ( FuncType && func )

inline

在文件 prediction_thread_pool.h 第 59 行定义.

                                                                         {
    typedef typename std::result_of<FuncType()>::type ReturnType;
    typedef typename std::packaged_task<ReturnType()> TaskType;
    // Post requires that the functions in it are copy-constructible.
    // We used a shared pointer for the packaged_task,
    // Since it's only movable and non-copyable
    std::shared_ptr<TaskType> task =
        std::make_shared<TaskType>(std::move(func));
    std::future<ReturnType> returned_future = task->get_future();
 
    // Note: variables eg. `task` must be copied here because of the lifetime
    if (stopped_) {
      return std::future<ReturnType>();
    }
    task_queue_.Enqueue([task]() { (*task)(); });
    return returned_future;
  }

◆ Stop()

void apollo::prediction::BaseThreadPool::Stop ( )

在文件 prediction_thread_pool.cc 第 44 行定义.

                          {
  task_queue_.BreakAllWait();
  for (std::thread& worker : workers_) {
    worker.join();
  }
  stopped_ = true;
}

类成员变量说明

◆ THREAD_POOL_CAPACITY

std::vector< int > apollo::prediction::BaseThreadPool::THREAD_POOL_CAPACITY = {20, 20, 20}

static

在文件 prediction_thread_pool.h 第 77 行定义.

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

modules/prediction/common/prediction_thread_pool.h
modules/prediction/common/prediction_thread_pool.cc

Public 成员函数

静态 Public 属性