Надо дождаться двух сигналов

[Гурман]

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

основной поток:

Код:

    QMutex m( QMutex::Recursive );
    m.lock();
    m.lock();
    QWaitCondition w;
    w.wait( &m );

соответственно в слотах для сигналов от потоков 1 и 2, в обоих:

Код:

    w.wakeOne();

но облом, в мануале написано, что w.wait() освободит кумутекс, если он рекурсивный - проверил, действительно, wait проскакивает

вот пока что-то не могу придумать изящное решение на ночь глядя, оно наверняка очень простое, может кто подскажет? хотелось бы, чтобы без перезапуска ожидания в ловушках сигналов, так я без подсказки могу сделать

[BRE]

QSemaphore?

[Гурман]

ну и как его в главном потоке приложения использовать? задерживать два других потока мне не нужно - они присылают сигналы, когда им надо, через QueuedConnection, и как-то сами крутятся

то есть, в классе, который в главном потоке должен их подождать, есть два слота приемников этих сигналов

как тут QSemaphore прикрутить? кто и как делает wait()? особенно, с учетом, что это все находится хоть и в главном потоке, но не в основном приложении - это в плагине

[BRE]

Про семафор это скорее были мысли в слух...
"wait" делает он сам при попытке захватить ресурс сверх лимита.

[Гурман]

Про семафор это скорее были мысли в слух...

аааа...

wait делает он сам при попытке захватить ресурс сверх лимита.

это я понимаю, поэтому с семафорами тоже ерунда получается - он не может остановиться до тех пор, пока ДВА ресурса не освободятся, он побежит дальше, как только освободится один

[BRE]

Основной поток:

Код

C++ (Qt)
QMutexLocker locker( &m );
while( numThread > 0 )
	w.wait( &m );
 

Изначально numThread = 2, каждый поток при завершении должен сделать декремент под защитой мутекса m, ну и wakeOne.

[Гурман]

Основной поток:

Код

C++ (Qt)
QMutexLocker locker( &m );
while( numThread > 0 )
	w.wait( &m );
 

Изначально numThread = 2, каждый поток при завершении должен сделать декремент под защитой мутекса m, ну и wakeOne.

надо разобраться...

[BRE]

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

[Гурман]

QWaitCondition на очередь событий не влияет

[BRE]

Влияет, wait поток останавливает! Иначе в нем смысла не было бы.

[Гурман]

он останавливает только главный поток, но не обработку событий, иначе у меня не работали бы "двунаправленные сокет-слоты", то есть, "сигналы с возвратом значения", вот такие:

Код:

void class::sender( int somevalue )
{
    QMutex mutex;
    mutex.lock();
    emit send( somevalue );  // послали другому объекту сигнал
    waiter.wait( &mutex, 1000 ); // и ждем его ответа
    mutex.unlock();
    process( 0.0 );
}

// это слот, в который другой объект присылает ответ
void class::receiver( float returnedvalue ) // SLOT
{
    waiter.wakeAll();
    process( returnedvalue );
}

кстати, тогда и таймер бы не работал у самого wait, и интерфейс бы блокировался, но этого не происходит

[Гурман]

а зачем там QMutexLocker ? какой в нем тут смысл?

[BRE]

wait таймеры не использует.
А зачем ты у wait таймаут используешь? А если его убрать?
Ну и твой кусок кода ничего не показывает, ни очередь событий, ни "сигналы с возвратом значений".

Главное! wait останавливает поток, наглухо. Останавливается все, включая очередь сообщений. Это то, для чего он предназначен.

[BRE]

а зачем там QMutexLocker ? какой в нем тут смысл?

Безопасно залочить мьютекс.

[Гурман]

я строку добавил, которая показывает, зачем таймаут - если другой объект не отозвался, то считается, что результат 0.0

но ведь у меня это все работает через соединения QueuedConnection, и что еще смешнее - другой объект, который сигнал принимает, тоже в главном потоке находится

твой кусок кода ничего не показывает, ни очередь событий, ни "сигналы с возвратом значений"

так показывает?

Код:

Объект1::<сигнал>send(somevalue) --> Объект2::<слот>recevie(somevalue)...чего-то сделал...Объект2::<сигнал>sendresult(returnedvalue) --> Объект1::<слот>receiver(returnedvalue)

оба объекта в главном потоке, все работает на ура, несмотря на wait()

если соединения нет (второй объект в другом плагине, а он может быть не загружен), то через 1 секунду получаю 0.0, если соединение есть, то ответ от второго объекта

а думаю, wait где-то внутри упирается в qnoop(), который в основном цикле ожидания используется

Безопасно залочить мьютекс.

а какая может быть опасность?