QThread, ожидание в потоке

[0xFF]

Доброго времени суток
Функция run() выглядит примерно так

Код

C++ (Qt)
void myThread::run() {
	for(int i=0; i<dataSize; ++i) {
		obj->func(i);
		...
		stopped = false;
		while( !stopped ) {}
	}
}

Собственно нужно подождать пока выполнится obj->func(i),  для этого использую while( !stopped ) {}, переменная stopped меняется при поступлении сигнала от obj.
Но что-то этот while( !stopped ) {} кажется каким-то "говнистым", есть другие способы?

[SimpleSunny]

Можно добавить слот, в который будет приходить сигнал.

Код:

f1()
{
if (i >= dataSize())
quit;

obj->func(i);
}

f2()
{
++i;
f1();
}

run()
{
i = 0;
f1();
exec();
}

[alexman]

Код:

void myThread::run() {
	for(int i=0; i<dataSize; ++i) {
		obj->func(i);
		...
		QMutex m;
                m.lock();

                waitCondition.wait( &m );
	}
}

waitCondition - это QWaitCondition. А там где ты меняешь stopped, сделай waitCondition.wakeOne();

[alexman]

Код

C++ (Qt)
		stopped = false;
		while( !stopped ) {}
 

Так плохо! Процессор конкретно грузим!

[0xFF]

Хм, спасибо за ответы.

[Igors]

Код

C++ (Qt)
void myThread::run() {
	for(int i=0; i<dataSize; ++i) {
		obj->func(i);
		...                       // что если stopped = true будет в этот момент?
		stopped = false;    // или в этот?
		while( !stopped ) {}  //  а не в этот как рассчитывали
	}
}

QMutex здесь не подходит, если нитка захватила мутекс - она же (и только она) должна его освободить. Цивильное решение - использовать семафор

Код

C++ (Qt)
QSemaphore theSemaphore;
...
void myThread::run() {
	for(int i=0; i<dataSize; ++i) {
                theSemaphore.acquire();
		obj->func(i);
	}
}

А "наблюдающий" должен открыть семафор

Код:

theSemaphore.release();

[alexman]

Код

C++ (Qt)
void myThread::run() {
	for(int i=0; i<dataSize; ++i) {
		obj->func(i);
		...                       // что если stopped = true будет в этот момент?
		stopped = false;    // или в этот?
		while( !stopped ) {}  //  а не в этот как рассчитывали
	}
}

QMutex здесь не подходит, если нитка захватила мутекс - она же (и только она) должна его освободить. Цивильное решение - использовать семафор

void myThread::run() {
       QMutex m;
   for(int i=0; i<dataSize; ++i) {
      obj->func(i);
      ...
                m.lock();
                waitCondition.wait( &m );
                m.unlock();
   }
}

А там где ты меняешь stopped, сделай waitCondition.wakeOne();

[Igors]

Через waitCondition тоже можно, но тогда по-моему так

Код

C++ (Qt)
void myThread::run() {
       QMutex m;
	for(int i=0; i<dataSize; ++i) {
                m.lock();
		obj->func(i);
		...
                waitCondition.wait( &m );
                m.unlock();
	}
}
 

[alexman]

Смысл? wakeOne может вызваться только после obj->func(i) (это конечно, если я код правильно понимаю ).

[Igors]

Смысл? wakeOne может вызваться только после obj->func(i) (это конечно, если я код правильно понимаю ).

wakeOne вызывается из др. нитки, поэтому если оно придет до того как мутекс заперт - будет не гуд

[alexman]

Смысл? wakeOne может вызваться только после obj->func(i) (это конечно, если я код правильно понимаю ).

wakeOne вызывается из др. нитки, поэтому если оно придет до того как мутекс заперт - будет не гуд

Точняк

[Igors]

Нет, не выплясывается через wakeOne - этот метод не имеет эффекта если нет "ожидающих". Значит если wakeOne проскочит до wait - тому остается ждать forever 

Мда... а на примерах все так легко и понятно 

[SASA]

Код:

bool stopped;
QMutex stoppedMutex;

void setStopped(bool _s)
{
	stoppedMutex.lock();
	stopped = _s;
	stoppedMutex.unLock();
}
bool sStopped()
{
	stoppedMutex.lock();
	return stopped;
	stoppedMutex.unLock();

}
void run()
{
	...
	while( !isStopped() ) { sleep(1); }  //  а не в этот как рассчитывали
	...
}

Работает, процессор не грузит.
Но если семафор позволяет работать из разных потоков, он будет быстрее.

[alexman]

Код:

bool stopped;
QMutex stoppedMutex;

void setStopped(bool _s)
{
	stoppedMutex.lock();
	stopped = _s;
	stoppedMutex.unLock();
}
bool sStopped()
{
	stoppedMutex.lock();
	return stopped;
	stoppedMutex.unLock();

}
void run()
{
	...
	while( !isStopped() ) { sleep(1); }  //  а не в этот как рассчитывали
	...
}

Работает, процессор не грузит.
Но если семафор позволяет работать из разных потоков, он будет быстрее.

Под виндой не скомпилится!

[pastor]

Код

C++ (Qt)
bool sStopped()
{
	stoppedMutex.lock();
	return stopped;
	stoppedMutex.unLock();
 
}

unLock после return это сильно.