ожидание события, потоки

[boriska]

здрасте, пишу программу под линукс с помощью qt.
подскажите аналог WinApi функции WaitForSingleOject().
дело в том, что есть два не-GUI потока, которые крутятся в бесконечном цикле.
поток №2 перед началом выполнению очередного цикла должен дождаться сигнала от потока №1.
на windows это было реализовано с помощью событий

[ssoft]

Использовать общий QMutex.

[kuzulis]

здрасте, пишу программу под линукс с помощью qt.
подскажите аналог WinApi функции WaitForSingleOject().

o_O лолчто? Ты хоть определись и конкретизируй ОС, а то на ЛОР-е ты не написал.

А так - QWaitCondition тебе уже на ЛОР-е подсказали. См. Qt-шные примеры.

[Igors]

А так - QWaitCondition тебе уже на ЛОР-е подсказали.

QWaitCondition может "вынести моск". Для того что рассказал автор темы хорош QSemaphore

[twp]

подскажите аналог WinApi функции WaitForSingleObject().

а с каким дескриптором используется WaitForSingleObject()?
Она может использоваться как с потоком так и с мютексом.
тогда соответсвенно нужно смотреть на классы QThread и QMutex, а может и QWaitCondition

[Bepec]

QWaitCondition выносит мозг. Согласен с этим

[Dancing_on_water]

Если время исполнение кода, который исполняется во втором потоке, после приема сигнала с первого, невелико, то пользовать QMutex (самый простой вариант в случае двух потоков).
Если время исполнения невелико как в первым, так и втором потоке,  то лучше смотреть в сторону QAtomicInt и QAtomicPointer и юзать неблокирующую синхронизацию.
 
Если исполняемый код большой, то лучше делать через синалы-слоты.
Пользовать семафор надо лишь в случае 3 и более потоков.

Короче, нужна конкретика.

[Igors]

Короче, нужна конкретика.

Хорошо, вот простейшая задачка что соответствует изложенной в посте 1

- одна нитка ждет символ с клавиатуры (напр getchar), а другая этот символ печатает (напр printf)

Ваше решение?

[Dancing_on_water]

Запихнул в один поток, оверхед на синхронизацию слишком велик.

[Igors]

Запихнул в один поток, оверхед на синхронизацию слишком велик.

А у Вас нет выбора что куда пихать - нитка 1 умеет только читать, нитка 2 - только печатать. Да и сказки про ужасный оверхед рассказывать не стоит 

[Dancing_on_water]

Сферически дурацкие задачи не решаю.
А оверхед для этой задачи жуткий: как не делай, но уже самое ожидания потока на выдачу займет больше процессорного времени, чем исполнение команды.
(это если предположить, что у нас на все про все есть один конвеер или раскидывание потоков по конвеерам мы не занимеамся)
Конечно, если предположить, что у нас уже есть два конвеера, и на одном сидит один поток и на другом другой. то стоит смотреть на неблокирующую синхронизацию си атомические типы.

[Igors]

Сферически дурацкие задачи не решаю.
А оверхед для этой задачи жуткий: как не делай, но уже самое ожидания потока на выдачу займет больше процессорного времени, чем исполнение команды.
(это если предположить, что у нас на все про все есть один конвеер или раскидывание потоков по конвеерам мы не занимеамся)
Конечно, если предположить, что у нас уже есть два конвеера, и на одном сидит один поток и на другом другой. то стоит смотреть на неблокирующую синхронизацию си атомические типы.

Ой наплели "с три короба" - вместо того чтобы написать неск строк кода   А atomic здесь вообще "як собацi п'ята лапа" 

[Dancing_on_water]

Троллинг жирный, тоньше надо, тоньше.

Задача постановлена в терминах "а допустим". И ответ дан в том же ключе.

Насчет атомиков: а давно вы смотрели код синхронизирующих примитивов в qt? или код контейнеров?

[Igors]

Задача постановлена в терминах "а допустим". И ответ дан в том же ключе.

Насчет ответа - то да. А вопрос был вполне нормальный

есть два не-GUI потока, которые крутятся в бесконечном цикле.
поток №2 перед началом выполнению очередного цикла должен дождаться сигнала от потока №1.

Вот простой способ это сделать

Код

C++ (Qt)
// thread 2
while (true) {
 theSemaphore.acquire();
 ...
}
 
// thread 1
..
theSemaphore.release();
 

Конечно это не единственное решение, но в упор не вижу как это сделать на QMutex и причем тут atomic(и) 

[Dancing_on_water]

Да, насчет QMutex это я сказанул (конструкции придумал, но вот где они могут быть использованы не понятно). Нужно юзать QWaitCondition.

А с атомиками можно придумать что-то типа такого:

Код:

глобально:
QAtomicInt buffer;

поток 1:

char tmp;

char = getchar();

buffer.fetchAndStoreOrdered(tmp);

поток 2:

while(1)
{
  if(buffer != -257)
  {
   std::cout<<buffer;
   buffer.fetchAndStoreOrdered(-257);
  }
}