C++ синхронизированные этапы мульти нить трубопровода

Question

Извините, если это было предложено, я сделал все возможное, чтобы искать DUP, прежде чем спрашивать ...

Я реализую приложение для обработки видео, который должен работать в режиме реального времени. Обработку, которую он делает, можно легко разделить на 4 этапа, каждый из которых работает на промежуточных значениях, полученных на предыдущем этапе. Обработка стала тяжелее, чем то, что может быть обработано за 1/30-е секунды, но если я могу разбить это приложение на 4 потока и превратить его в конвейер, каждый этап займет меньше, и все это будет работать в реальном времени (с 4 кадра, что вполне приемлемо).

Я довольно новичок в многопоточном программировании, и проблема, с которой я сталкиваюсь, заключается в том, что я не могу найти механизм для запуска/остановки каждого потока в начале каждого кадра, поэтому все они идут вместе, доставляя один закончил кадр каждый «цикл» в конце. Все найденные фреймворки/библиотеки, похоже, беспокоятся о балансировке нагрузки с использованием очередей и рабочих потоков, но это не то, что мне нужно здесь. Будут делать четыре потока, предполагая, что я смогу их синхронизировать.

Может ли кто-нибудь указать мне исходную точку, используя C++?

Спасибо.

Answer 1

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

Вот ссылка на примерную программу копирования файлов, которая порождает поток для записи. Он использует потоки Windows, мьютексы и семафоры в функциях обмена сообщениями, но функции обмена сообщениями просты и могут быть изменены внутренне, чтобы использовать общие эквиваленты без изменения их интерфейса. Функция main() может быть изменена для использования общей потоковой передачи и установки мьютексов и семафоров или чего-то эквивалентного.

mtcopy.zip