plebble
us::gov::socket::thpool Struct Referencefinal

#include <thpool.h>

Inheritance diagram for us::gov::socket::thpool:
Collaboration diagram for us::gov::socket::thpool:

Public Member Functions

 thpool (daemon *d)
 
 ~thpool ()
 
ko start (size_t sz)
 
ko wait_ready (const chrono::system_clock::time_point &deadline) const
 
void stop ()
 
void join ()
 
void process (peer_t *p)
 
void run ()
 
void watch (ostream &) const
 

Public Attributes

unordered_set< peer_t * > q
 
condition_variable cv
 
mutex mx_q
 
daemond
 
atomic< short > resume {0}
 
mutex mx
 

Constructor & Destructor Documentation

◆ thpool()

us::gov::socket::thpool::thpool ( daemon d)

◆ ~thpool()

us::gov::socket::thpool::~thpool ( )

Member Function Documentation

◆ 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

Member Data Documentation

◆ cv

condition_variable us::gov::socket::thpool::cv

◆ d

daemon* us::gov::socket::thpool::d

◆ mx

mutex us::gov::socket::thpool::mx

◆ mx_q

mutex us::gov::socket::thpool::mx_q
mutable

◆ q

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: