nesca/Threader.cpp

#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;
}