nesca/Threader.cpp
2015-04-04 15:43:22 +03:00

37 lines
760 B
C++

#include "Threader.h"
int Threader::threadId = 0;
std::mutex Threader::m;
bool Threader::ready = false;
std::condition_variable Threader::cv;
std::queue<std::string> Threader::ipQueue;
void Threader::fireThread(std::string ip, void *func(void)) {
ipQueue.push(ip);
if(threadId < gThreads) {
++threadId;
std::thread workerThread(func);
workerThread.detach();
}
ready = true;
cv.notify_one();
Sleep(gThreadDelay);
}
void Threader::cleanUp() {
ready = true;
cv.notify_all();
//Wait for threads to exit correctly
Sleep(gTimeOut*1000 + 2000);
std::unique_lock<std::mutex> lk(m);
lk.unlock();
lk.release();
threadId = 0;
std::queue<std::string> empty = {};
std::swap(ipQueue, empty);
ready = false;
}