: signaled(signaled), manually(manually)

{

{

if (this->signaled.load() == false) {

std::unique_lock<std::mutex> lck(this->mtx);

do {

this->cv.wait(lck);

}

while (this->signaled.load() == false);

}

if (false == this->manually) {

this->signaled.store(false);

}

{

bool is_timeout = false;

if (this->signaled.load() == false) {

std::unique_lock<std::mutex> lck(this->mtx);

is_timeout = false == this->cv.wait_for(lck, ms, [this] {

return this->notifed();

});

}

if (false == this->manually) {

this->signaled.store(false);

}

return is_timeout;

const std::chrono::high_resolution_clock::time_point &tp

) {

bool is_timeout = false;

if (this->signaled.load() == false) {

std::unique_lock<std::mutex> lck(this->mtx);

do {

if (std::cv_status::timeout == this->cv.wait_until(lck, tp) ) {

is_timeout = true;

break;

}

}

while (this->signaled.load() == false);

}

if (false == this->manually) {

this->signaled.store(false);

}

return is_timeout;

this->signaled.store(true);

for (size_t i = 0; i < threadsCount; ++i) {

this->cv.notify_one();

}