carla::ThreadPool类 参考

基于Boost.Asio的上下文 更多...

#include <ThreadPool.h>

类 carla::ThreadPool 继承关系图:

carla::ThreadPool 的协作图:

Public 成员函数
void	AsyncRun ()
void	AsyncRun (size_t worker_threads)
auto &	io_context ()
template<typename FunctorT , typename ResultT = typename std::result_of<FunctorT()>::type>
std::future< ResultT >	Post (FunctorT &&functor)
void	Run ()
void	RunFor (time_duration duration)
void	Stop ()
	ThreadPool ()
	~ThreadPool ()
	停止线程池ThreadPool并合并所有线程

Private 属性
boost::asio::io_context	_io_context
boost::asio::io_context::work	_work_to_do
ThreadGroup	_workers

额外继承的成员函数
Private 成员函数 继承自 carla::NonCopyable
	NonCopyable ()=default
	NonCopyable (const NonCopyable &)=delete
	NonCopyable (NonCopyable &&)=delete
NonCopyable &	operator= (const NonCopyable &)=delete
NonCopyable &	operator= (NonCopyable &&)=delete

详细描述

基于Boost.Asio的上下文

在文件 ThreadPool.h 第 24 行定义.

构造及析构函数说明

ThreadPool()

carla::ThreadPool::ThreadPool ( )

inline

在文件 ThreadPool.h 第 27 行定义.

~ThreadPool()

carla::ThreadPool::~ThreadPool ( )

inline

停止线程池ThreadPool并合并所有线程

在文件 ThreadPool.h 第 30 行定义.

引用了 Stop().

函数调用图:

成员函数说明

AsyncRun() [1/2]

void carla::ThreadPool::AsyncRun ( )

inline

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

引用了 AsyncRun().

被这些函数引用 AsyncRun().

函数调用图:

这是这个函数的调用关系图:

AsyncRun() [2/2]

void carla::ThreadPool::AsyncRun ( size_t worker_threads )

inline

在文件 ThreadPool.h 第 62 行定义.

引用了 _workers, carla::ThreadGroup::CreateThreads() , 以及 Run().

被这些函数引用 carla::streaming::Client::AsyncRun(), carla::streaming::Server::AsyncRun(), TEST() , 以及 TEST().

函数调用图:

这是这个函数的调用关系图:

io_context()

auto & carla::ThreadPool::io_context ( )

inline

在文件 ThreadPool.h 第 35 行定义.

引用了 _io_context.

被这些函数引用 carla::streaming::Client::Subscribe().

这是这个函数的调用关系图:

Post()

template<typename FunctorT , typename ResultT = typename std::result_of<FunctorT()>::type>

std::future< ResultT > carla::ThreadPool::Post ( FunctorT && functor )

inline

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

引用了 _io_context , 以及 carla::MoveHandler().

被这些函数引用 TEST() , 以及 TEST().

函数调用图:

这是这个函数的调用关系图:

Run()

void carla::ThreadPool::Run ( )

inline

在文件 ThreadPool.h 第 97 行定义.

引用了 _io_context.

被这些函数引用 AsyncRun(), carla::streaming::Client::Run() , 以及 carla::streaming::Server::Run().

这是这个函数的调用关系图:

RunFor()

void carla::ThreadPool::RunFor ( time_duration duration )

inline

在文件 ThreadPool.h 第 114 行定义.

引用了 _io_context , 以及 carla::time_duration::to_chrono().

函数调用图:

Stop()

void carla::ThreadPool::Stop ( )

inline

在文件 ThreadPool.h 第 132 行定义.

引用了 _io_context, _workers , 以及 carla::ThreadGroup::JoinAll().

被这些函数引用 carla::streaming::Client::~Client(), carla::multigpu::Secondary::~Secondary(), carla::streaming::Server::~Server() , 以及 ~ThreadPool().

函数调用图:

这是这个函数的调用关系图:

类成员变量说明

_io_context

boost::asio::io_context carla::ThreadPool::_io_context

private

在文件 ThreadPool.h 第 150 行定义.

被这些函数引用 io_context(), Post(), Run(), RunFor() , 以及 Stop().

_work_to_do

boost::asio::io_context::work carla::ThreadPool::_work_to_do

private

在文件 ThreadPool.h 第 152 行定义.

_workers

ThreadGroup carla::ThreadPool::_workers

private

在文件 ThreadPool.h 第 156 行定义.

被这些函数引用 AsyncRun() , 以及 Stop().

---

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

• ThreadPool.h