#include <thread_pool.h>

apollo::perception::lib::ThreadPool 的协作图:

Public 成员函数
	ThreadPool (int num_workers)

	~ThreadPool ()

void	Start ()

void	Add (google::protobuf::Closure *closure)

void	Add (const std::vector< google::protobuf::Closure * > &closures)

int	num_workers () const

int	num_available_workers () const

	ThreadPool (const ThreadPool &)=delete

ThreadPool &	operator= (const ThreadPool &)=delete

友元
class	ThreadPoolWorker

详细描述

在文件 thread_pool.h 第 33 行定义.

构造及析构函数说明

◆ ThreadPool() [1/2]

apollo::perception::lib::ThreadPool::ThreadPool ( int num_workers )

explicit

在文件 thread_pool.cc 第 27 行定义.

    : num_workers_(num_workers),
      num_available_workers_(num_workers),
      task_queue_(num_workers),
      started_(false) {
  workers_.reserve(num_workers_);
  for (int idx = 0; idx < num_workers_; ++idx) {
    ThreadPoolWorker *worker = new ThreadPoolWorker(this);
    workers_.push_back(worker);
  }
}

◆ ~ThreadPool()

apollo::perception::lib::ThreadPool::~ThreadPool ( )

在文件 thread_pool.cc 第 39 行定义.

                        {
  if (!started_) {
    return;
  }
 
  for (int idx = 0; idx < num_workers_; ++idx) {
    Add(NULL);
  }
 
  for (int idx = 0; idx < num_workers_; ++idx) {
    workers_[idx]->Join();
    delete workers_[idx];
  }
}

◆ ThreadPool() [2/2]

apollo::perception::lib::ThreadPool::ThreadPool ( const ThreadPool & )

delete

成员函数说明

◆ Add() [1/2]

void apollo::perception::lib::ThreadPool::Add ( const std::vector< google::protobuf::Closure * > & closures )

◆ Add() [2/2]

void apollo::perception::lib::ThreadPool::Add ( google::protobuf::Closure * closure )

◆ num_available_workers()

int apollo::perception::lib::ThreadPool::num_available_workers ( ) const

inline

在文件 thread_pool.h 第 46 行定义.

46{ return num_available_workers_; }

◆ num_workers()

int apollo::perception::lib::ThreadPool::num_workers ( ) const

inline

在文件 thread_pool.h 第 44 行定义.

44{ return num_workers_; }

◆ operator=()

ThreadPool & apollo::perception::lib::ThreadPool::operator= ( const ThreadPool & )

delete

◆ Start()

void apollo::perception::lib::ThreadPool::Start ( )

在文件 thread_pool.cc 第 54 行定义.

                       {
  for (int idx = 0; idx < num_workers_; ++idx) {
    workers_[idx]->Start();
  }
  started_ = true;
}

友元及相关函数文档

◆ ThreadPoolWorker

friend class ThreadPoolWorker

friend

在文件 thread_pool.h 第 52 行定义.

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

modules/perception/common/lib/thread/thread_pool.h
modules/perception/common/lib/thread/thread_pool.cc

Public 成员函数

友元