#include <thpool.h>
◆ thpool()
us::gov::socket::thpool::thpool |
( |
daemon * |
d | ) |
|
◆ ~thpool()
us::gov::socket::thpool::~thpool |
( |
| ) |
|
◆ join()
void us::gov::socket::thpool::join |
( |
| ) |
|
◆ process()
void us::gov::socket::thpool::process |
( |
peer_t * |
p | ) |
|
◆ run()
void us::gov::socket::thpool::run |
( |
| ) |
|
◆ start()
ko us::gov::socket::thpool::start |
( |
size_t |
sz | ) |
|
◆ stop()
void us::gov::socket::thpool::stop |
( |
| ) |
|
◆ wait_ready()
ko us::gov::socket::thpool::wait_ready |
( |
const chrono::system_clock::time_point & |
deadline | ) |
const |
◆ watch()
void us::gov::socket::thpool::watch |
( |
ostream & |
| ) |
const |
◆ cv
condition_variable us::gov::socket::thpool::cv |
daemon* us::gov::socket::thpool::d |
◆ mx
mutex us::gov::socket::thpool::mx |
◆ mx_q
mutex us::gov::socket::thpool::mx_q |
|
mutable |
unordered_set<peer_t*> us::gov::socket::thpool::q |
◆ resume
atomic<short> us::gov::socket::thpool::resume {0} |
The documentation for this struct was generated from the following file: