#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 |