Синхронизация потоков - уведомление о событии

Здравствуйте.

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

Ведь, если я правильно понял, при использовании для синхронизации объектов ядра типа "событие", первый поток будет тормозиться на WaitForSingleObject, и инструкции не будут выполняться дальше до получения сигнала о произошедшем событии.
Возможно, есть другие объекты ядра, позволяющие реализовать такое взаимодействие? Если нет, можно ли обойтись без периодического повторения запроса или периодической проверки некоторой "сигнальной" переменной?

0

Сообщение от yeng Ведь, если я правильно понял, при использовании для синхронизации объектов ядра типа "событие", первый поток будет тормозиться на WaitForSingleObject, и инструкции не будут выполняться дальше до получения сигнала о произошедшем событии.

Не обязательно. Вторым параметром вызова этой ф-ции является таймаут. Можно вызывать ее с нулевым таймаутом и ожидания не будет. По возвращенному значению можно определить: истек ли таймаут (WAIT_TIMEOUT) при все еще занятом объекте синхронизации, или объект был отпущен (WAIT_OBJECT_0) до или во время вызова функции.

1

В С++ 11 есть conditional variables и wait_until с проверкой того, почему вышли. Это, чтобы писать более-менее отстраненно от платформы.
Во многих примитивах наряду с блокировкой можно указать время блокировки и узнать, вышел ли из-за того, что случилось что-то или по таймауту. И, судя по мсдн, WaitForSingleObject в их числе вместе с WAIT_TIMEOUT.

1

Сообщение от quwy Можно вызывать ее с нулевым таймаутом и ожидания не будет. По возвращенному значению можно определить: истек ли таймаут (WAIT_TIMEOUT) при все еще занятом объекте синхронизации, или объект был отпущен (WAIT_OBJECT_0) до или во время вызова функции.

Угу. Но я не могу придумать, как с помощью этого добиться реагирования на событие без остановки потока.
То есть мы выполнили WaitForSingleObject, получили таймаут, работаем дальше. Но ведь событие может произойти уже на следующем тике. То есть WaitForSingleObject нам придется в любом случае проверять либо постоянно, либо приурочивать проверку к каким-либо действиям. Например (в моем примере), переход по менюшке - проверка WaitForSingleObject. Но если пользователь ничего не делает и программа находится в режиме ожидания...

Вот тут я перестал писать и понял, что вот то, что я собирался сделать: пользователь ничего не делает = первый поток ждет ввода данных от пользователя = выполняется инструкция ввода данных (cin, getch - не важно). По происшествию события я хотел нагло прервать выполнение этой функции и сделать что-то еще.

Извините, ум за разум зашел, нужно пойти поспать. Большое спасибо за ответы. Действительно, достаточно просто напихать WaitForSingleObject в стратегических местах.

0