errMsgTest.cpp

Go to the documentation of this file.

#include "../errMsgQueue.h"
#include <list>
void produceMsg(int i) {
    errMsg::emit(errMsg::level::info,errMsg::location(),"start thread ",  i);
    std::this_thread::sleep_for(std::chrono::seconds(i));
    errMsg::emit(errMsg::level::err,errMsg::location(),"stop thread ", i);
}
 
int main(int argc, const char*argv[]) {
    std::thread errPrinter(errMsg::message::printMsgs);
    errMsg::emit(errMsg::level::debug,errMsg::location(),"we have ", argc, " args" , argv[0]);
 
    std::list<std::thread> threads;
    for (int i=0; i<argc; i++) {
        threads.emplace_back(produceMsg,i);
    }
    for (auto& t : threads) {
        t.join();
    }
    errMsg::message::getQueue().signalDone();
    errPrinter.join();
}