class to make sure all threads are joined before thread object is deleted in case of an exception to do so, all queues must be signalled as done More...

Collaboration diagram for queuesAndThreads:

[legend]

Public Member Functions
	queuesAndThreads ()=default

	~queuesAndThreads () noexcept(true)

Public Attributes
copyRequest::simpleQueue	requests

copyRequest::timedQueue	delayedRequests

copyRequest::simpleQueue	results

std::thread	printer

std::thread	delayer

std::forward_list< std::thread >	workers

Private Member Functions
template<class T >
void	stopQueue (T &queue, const std::string &name)

void	joinThread (std::thread &t)

Detailed Description

class to make sure all threads are joined before thread object is deleted in case of an exception to do so, all queues must be signalled as done

Definition at line 332 of file ewmscp.cpp.

Constructor & Destructor Documentation

◆ queuesAndThreads()

queuesAndThreads::queuesAndThreads ( )

default

◆ ~queuesAndThreads()

queuesAndThreads::~queuesAndThreads ( )

inlinenoexcept

Definition at line 355 of file ewmscp.cpp.

                                        {
         stopQueue(requests, "requests");
         stopQueue(delayedRequests, "delayedRequests");
         stopQueue(results, "results");
         joinThread(printer);
         joinThread(delayer);
         for (auto& worker : workers) {
             joinThread(worker);
         }
     }

References delayedRequests, delayer, joinThread(), printer, requests, results, stopQueue(), and workers.

Here is the call graph for this function:

Member Function Documentation

◆ joinThread()

void queuesAndThreads::joinThread ( std::thread & t )

inlineprivate

Definition at line 342 of file ewmscp.cpp.

                                   {
         if (t.joinable()) {
             t.join();
         }
     }

Referenced by ~queuesAndThreads().

Here is the caller graph for this function:

◆ stopQueue()

template<class T >

void queuesAndThreads::stopQueue	(	T &	queue,
		const std::string &	name
	)

inlineprivate

Definition at line 333 of file ewmscp.cpp.

                                                                        {
         try {
             queue.signalDone();
         } catch (const std::logic_error& e) {
             if (queue.size() > 1) {
                 errMsg::emit(errMsg::level::debug, errMsg::location(), name, "signalled", "done");
             }
         }
     }