#include <mutex>
#include <condition_variable>
#include <atomic>

class Event {
	std::condition_variable cv;
	std::mutex mtx;
	std::atomic<bool> need_wait = true;
public:
	// Ожидание
	void Wait() {
		if(need_wait) { // Попыток досрочно разбудить не было
			std::unique_lock<std::mutex> lck(mtx);
			cv.wait(lck);
		} 
		need_wait = true;
	}

	// Пробуждение ожидающего
	void WakeUp() {
		if(need_wait) {
			std::unique_lock<std::mutex> lck(mtx); 
			need_wait = false;
			cv.notify_one();
		}
	}
};

//*************************************************************************
// Пример использования
#include <thread>
#include <chrono>
#include <stdio.h>

Event event_test;

void event_thread() {
	printf("thread start\n");
	event_test.Wait();
	printf("thread wake\n");
	event_test.Wait();
	printf("thread end\n");
}

void main()
{
	printf("wake1\n");
	event_test.WakeUp();
	printf("thread\n");
	std::thread th(event_thread);
	std::this_thread::sleep_for(std::chrono::microseconds(100));
	printf("wake2\n");
	event_test.WakeUp();
	std::this_thread::sleep_for(std::chrono::microseconds(100));
	printf("wake3\n");
	event_test.WakeUp();
	std::this_thread::sleep_for(std::chrono::microseconds(100));
	th.join();
}

// Аналог EVENT в Windows
#include <mutex>
#include <condition_variable>
#include <atomic>

class Event {
	std::condition_variable cv;
	std::mutex mtx;
	std::atomic<bool> need_wait = true; // Флаг необходимости ожидания пробуждения
	std::atomic<bool> is_work = true; // Флаг что объект в рабочем режиме
public:
	// Ожидание. Возвращает false если вызван Stop()
	bool Wait() {
		std::unique_lock<std::mutex> lck(mtx);
		if (need_wait) { // Попыток досрочно разбудить не было
			if (is_work) cv.wait(lck);
		}
		need_wait = true;
		return is_work;
	}

	// Пробуждение ожидающего
	void WakeUp() {
		if(need_wait) {
			std::unique_lock<std::mutex> lck(mtx);
			need_wait = false; // нет ожидающих, следующий без ожидания
			cv.notify_one();
		}
	}

	// Пробуждение всех и остановка
	void Stop() {
		std::unique_lock<std::mutex> lck(mtx);
		is_work = false;
		cv.notify_all();
	}
};

//*************************************************************************
// Примеры использования
#include <thread>
#include <chrono>
#include <stdio.h>

Event event_test;

Event event_test2;
std::atomic<int> test2 = 0;

void event_thread2() {
	printf("thread\n");
	while (event_test.Wait()) {
		test2--;
		if (test2) event_test2.WakeUp();
	}
}

void Event_test2()
{
	std::thread th1(event_thread2);
	std::thread th2(event_thread2);
	std::thread th3(event_thread2);
	std::this_thread::sleep_for(std::chrono::milliseconds(50));
	std::chrono::steady_clock::time_point t1 = std::chrono::steady_clock::now();
	for (int i = 0; i < 1000000; i++) {
		test2 = 3;
		//printf("WakeUp() %d\r", i);
		event_test.WakeUp();
		event_test.WakeUp();
		event_test.WakeUp();
		event_test2.Wait();
	}
	event_test.Stop();
	std::chrono::steady_clock::time_point t2 = std::chrono::steady_clock::now();
	std::chrono::duration<double> time_span = std::chrono::duration_cast<std::chrono::duration<double>>(t2 - t1);
	printf("Time: %f sec\n", time_span);
	th1.join();
	th2.join();
	th3.join();
	return;
}