Message-Queues beta 1.1
A Message-Queues based Cpp
 
载入中...
搜索中...
未找到
XuMQ::threadpool类 参考

#include <threadpool.hpp>

Public 类型

using ptr = std::shared_ptr< threadpool >
 
using Functor = std::function< void(void)>
 

Public 成员函数

 threadpool (int thr_count=1)
 
 ~threadpool ()
 
void stop ()
 
template<typename F , typename... Args>
auto push (F &&func, Args &&...args) -> std::future< decltype(func(args...))>
 

Private 成员函数

void entry ()
 

Private 属性

std::atomic< bool > _stop
 
std::vector< Functor_taskpool
 
std::mutex _mutex
 
std::condition_variable _cv
 
std::vector< std::thread > _threads
 

成员类型定义说明

◆ Functor

using XuMQ::threadpool::Functor = std::function<void(void)>

◆ ptr

using XuMQ::threadpool::ptr = std::shared_ptr<threadpool>

构造及析构函数说明

◆ threadpool()

XuMQ::threadpool::threadpool ( int  thr_count = 1)
inline
函数调用图:

◆ ~threadpool()

XuMQ::threadpool::~threadpool ( )
inline
函数调用图:

成员函数说明

◆ entry()

void XuMQ::threadpool::entry ( )
inlineprivate
这是这个函数的调用关系图:

◆ push()

template<typename F , typename... Args>
auto XuMQ::threadpool::push ( F &&  func,
Args &&...  args 
) -> std::future<decltype(func(args...))>
inline

◆ stop()

void XuMQ::threadpool::stop ( )
inline
这是这个函数的调用关系图:

类成员变量说明

◆ _cv

std::condition_variable XuMQ::threadpool::_cv
private

◆ _mutex

std::mutex XuMQ::threadpool::_mutex
private

◆ _stop

std::atomic<bool> XuMQ::threadpool::_stop
private

◆ _taskpool

std::vector<Functor> XuMQ::threadpool::_taskpool
private

◆ _threads

std::vector<std::thread> XuMQ::threadpool::_threads
private