Dimitry SibiryakovОбработка ошибок в такой очереди будет весьма крепким орешком, однако...


Там тривиальная задача с набором из 2 семафоров.

Single-producer устанавливает значение входяжего семафора
на нужное количество consumer -ов , те ломятся в кадр , а Single-producer
засыпает на выходящем семафоре.
Закончив работу consumer -ы сбрасыают исходящий семафор
и засыпают на входящем.
Single-producer меняет указатель на следующий кадр и
снова запускает consumer -ов

И так по кругу.

ТС-у нужно изучить принципы работы семафоров.

Если Single-producer Single-consumer то достаточно одного семафора,
если их разное количество то нужен набор из 2 семафоров.

Я не знаю как в винде обстоят дела с атомарностью работы
с набором семафоров , возможно для защиты набора от рассогласования
придется их защищать мутексом .
В Юниксе работа с набором семафоров атомарна из коробки.

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

Читатели могут пользоваться ресурсом одновременно ,
а писатели только в одиночку.

Если такой примитив сихронизации где то уже реализован ,
то можно воспользоваться им.

Dimitry SibiryakovДохтаРSingle-producer устанавливает значение входяжего семафора на нужное
количество consumer -ов , те ломятся в кадр , а Single-producer засыпает на выходящем
семафоре.
Закончив работу consumer -ы сбрасыают исходящий семафор и засыпают на входящем.
Single-producer меняет указатель на следующий кадр и снова запускает consumer -ов

И так по кругу.
И вот тут-то возникает вопрос: что делать если у пятого из десяти consumer-ов в ходе
работы произошла ошибка? Прервать всю работу и оповестить остальных, что последний
обработанный ими кадр нужно дропнуть? Или пропустить кадр только этим consumer-ом и
получить несогласованные потоки на выходе?



Можно создать битовый массив при каждом кадре
пусть каждый consumer зводит свой
бит если все ОК, а потом сравнивать его с 0xFF....FF маской.
Если битовый масив маске не соотвествует значит кто то из consumer -ов
зафейлился.

Dimitry SibiryakovДохтаРЕсли битовый масив маске не соотвествует значит кто то из consumer -ов
зафейлился.
"А дальше?.." (с) ПВ

Обнаружить факт ошибки - просто. Но лично мне в аналогичной задаче пока не удалось
придумать приемлемую схему реакции на ошибку. Проблема становится ещё хуже, если очередь
удлинить, позволяя тормозному продюсеру готовить следующую порцию данных в то время как
консюмеры обрабатывают предыдущие.


А дальше зависит от цели, которую преследует решение здачи.