Потоки, синхронизация, простой

[denrubun]

Уважаемые форумчане, нужна ваша помощь!

есть вот такая функция для потока:

DWORD WINAPI event_engine::main_loop(LPVOID x){
	event_engine *t = (event_engine *)x;
	event_queue::event_iter cur, end = t->_events.end();
	while(true){
		cur = t -> _events.begin();
		if(cur == end){  //события закончились, остановка
			cout << "event_queue is empty. thread stopped\n";
			t->stop();
		}
		else if(t->getCurTime() >= (*cur)->gettime()){	  //событие должно произойти
			
			EnterCriticalSection( &(t->_crt) );

			(*cur)->happen();  //происходит
			t->_events.pop_front();  //удаляется
			
			LeaveCriticalSection( &(t->_crt) );
		}
		else{	  //события есть, но еще не время
			t->setstate(Waiting);
			cout << "_state set to 'Waiting'. thread paused\n";
			//Sleep( (*cur)->gettime() - t->getCurTime());	  //ждем наступления первого события
		}
	}
	return 0;
};

занимается просмотром событий в очереди и выполнением их, если время настало.

если события кончились, останавливает поток, а добавление нового события его снова запустит.

а если событие не наступило, его надо подождать.
Вопрос в ток как это сделать:

если повесить Sleep, тогда при добавлении нового события, которое должно случиться раньше первого(на момент Sleep'а)
поток продолжит спать, и выполнится не раньше намеченного времени.

а если ничего не сделать цикл будет вхолостую крутиться и подъедать ресурсы, но работать будет правильно.

есть какой-нибудь аналог слипа, который можно разбудить?

[counter]

SuspendThread \ ResumeThread

WaitForsingleObject \ WaitForMultipleObjects

[waleri]

Прочитайте про семафоры.

[denrubun]

если я заюзаю SuspendThread:
если за время простоя добавится новое событие в начало очереди, то все ок.
но если события не добавится, кто разбудит поток во время наступления первого события?

WaitForSingleObject я не могу использовать, это не библиотечный Event, а мой, самописный, в нем содержится только время, когда он должен быть выполнен.

=======================

есть вариант Sleep(50) ,например. будет проверять каждые 50 миллисекунд, все лучше чем постоянно крутиться.

и все же хотелось бы что-то вроде SuspendThread, только еще с параметром времени, как в WaitForSingleObject, но как это сделать, я пока не знаю

[waleri]

Каждый, кто добавит в очередь будет вызвать ResumeThread(), после извлечения и выполнения каждого елемента из очереди рабочий поток будет вызывать SuspendThread(). При создании рабочега потока сразу вызываем SuspendThread() (или прямо создаем поток спящим).

Одно непонятно - зачем изобретать колесо а не прочитать про семафоры?
Далее, почему нельзя использовать WaitForSingleObject но можно использоват ResumeThread, Sleep, etc?

Зачем вообще нужен параметр времени? Это когда используем Sleep, только Sleep очень вредная функция...

[denrubun]

Каждый, кто добавит в очередь будет вызвать ResumeThread(), после извлечения и выполнения каждого элемента из очереди рабочий поток будет вызывать SuspendThread(). При создании рабочего потока сразу вызываем SuspendThread() (или прямо создаем поток спящим).

все правильно поняли. Или у вас есть претензии к такому подходу?

Далее, почему нельзя использовать WaitForSingleObject но можно использовать ResumeThread, Sleep, etc?

не нельзя, просто я не знаю как. Ведь она ожидает дескриптора ресурса, который может сигнализировать о состоянии, а у меня только мой простой класс.
Или вы предлагаете дополнить/заменить его?
Мой класс Event является базовым для всех событий в игре, он никак не связан с библиотечным, вообще никак.

class Event{
protected:
	time_t _time;
public:
	Event(){
		_time = GetTickCount() / (float)CLOCKS_PER_SEC * 1000;
	};

	Event(const time_t &timeDelta) {
		_time = GetTickCount() / (float)CLOCKS_PER_SEC * 1000 + timeDelta;
	};

	bool operator<(const Event &other){
		return (_time < other._time);
	};

	bool operator==(const Event &other){
		return (_time == other._time);
	};

	virtual void happen() {
		cout << "event happened at " << GetTickCount() << "\n\n";
	};
	time_t gettime() const {
		return _time;
	};
};

только Sleep очень вредная функция...

почему?

из вики:

Семафо́р — объект, позволяющий войти в заданный участок кода не более чем n потокам. Определение введено Эдсгером Дейкстрой.
Семафоры используются при передаче данных через разделяемую память.

ну так у меня не в семафорах проблема, и не в совместном доступе, а в том как мне правильно организовать ожидание. Или я не понял вашей мысли?

[waleri]

Сообщение от denrubun

Или у вас есть претензии к такому подходу?

Мне по барабану.

Сообщение от denrubun

а в том как мне правильно организовать ожидание.

Ожидание делается через функции ожидания - WaitForSingleObject() о чем вам сказали в первом же ответе.
CreateEvent(), SetEvent(), WaitForSingleObject() - для одного потока этого вполне достаточно.
Если надо несколько рабочих потоков (что лучше) то лучше использовать семафоры. Нет, можно сделать тем же SetEvent() но надо будет изобретать велосипед.

[denrubun]

т.е. мне нужно создать событие с помощью CreateEvent() и повесить ожидание этого события с помощью WaitForSingleObject().
тогда нужно в нужное время чтобы это событие отсигналило и ожидание прекратилось.
т.е. таки прикрутить к этому еще таймер?

[counter]

Сообщение от denrubun

не нельзя, просто я не знаю как. Ведь она ожидает дескриптора ресурса, который может сигнализировать о состоянии, а у меня только мой простой класс.
Или вы предлагаете дополнить/заменить его?
Мой класс Event является базовым для всех событий в игре, он никак не связан с библиотечным, вообще никак.

Что Вам мешает дополнить свой класс до состояния стандартного Event'а ?
К тому же можно в Wait-функцию передать дескриптор вашего объекта, после его разрушения функция вернет управление.

Еще есть такие вещи как таймеры ожидания и условные переменные:
Waitable Timer
Condition Variables

[denrubun]

Спасибо, думаю вопрос решен!