#include <threadpool.hpp>
|
| threadpool (int thr_count=1) |
|
| ~threadpool () |
|
void | stop () |
|
template<typename F , typename... Args> |
auto | push (F &&func, Args &&...args) -> std::future< decltype(func(args...))> |
|
◆ Functor
◆ ptr
◆ 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 |