Здравствуйте!
Решаю задачу синхронизации процессов в Linux.
Задача первая и главная. Есть два/три процесса, все они получают одни и те же сообщения, примерно одновременно. Один из этих процессов, давайте называть ведущим, остальные - ведомыми. Необходимо при получении одного, из всего изобилия сообщений, ведущим процессом устанавливать некоторые значения для ведомых, ведомые же приостанавливать до окончания записи этих значений. А после, на ведомых, делать выбор между запуском функции обработки сообщения или продолжением работы без обработки.
Т.е. это похоже на очередь с "буфером" равным 1 или 2 (в зависимости от количества ведомых процессов). Причем ведущий процесс ничего не обрабатывает, а лишь, выдает команды, основываясь на знании того, сколько ведомых процессов в данный момент заняты обработкой: отдать 1му, отдать 2му, сбросить. Прелесть такого способа хороша, когда необходимо знать, сколько сообщений было отброшено (ведь процесс не имеет возможности слушать сообщения во время обработки).
В данном случае, семафоры хотелось бы использовать для организации блокировки (т.е. ожидания готовности данных, но не более), а так же для передачи этих самых данных. Под данными я подразумеваю счетчик, определяющий сколько процессов свободны, и какие из них свободны (например двухбитный флаг).
Вторая задача - это упразднение ведущего процесса. Теперь все процессы равнозначны по задачам. Это дает выигрыш в обработке, так как третий процесс может быть задействован. Но здесь возникает вопрос, как синхронизировать процессы, чтобы не дать двум и более процессам обрабатывать одно и то же сообщение.
Для решения этой задачи я бы использовал все те же семафоры, позволяющие "следить" за счетчиком процессов, и, теперь уже, трехбитный флаг, который решает теперь две задачи: задачу выбора обрабатывающего процесса, по старшинству нулевого бита, и задачу идентификации свободных процессов.
Но, столкнулся с трудностями, не могу до конца осознать необходимые действия после получения идентификатора семафора в Linux. Пользуясь возможностями ftok
, получаю уникальный ключ к своему семафору. Далее через sem_get
получаю сам семафор или его создаю.
А дальше куда глядеть? Есть адекватное описание функций для реализации того, что мне нужно (развернутое описание того, что функция делает, какие параметры и каких типов принимает, что возвращает)? Не откажусь и от направления мыслей в области решения второй задачи. Все еще усугубляется тем, что блокировка процессов должна быть минимальной, любые задержки чреваты. Код должен быть легким, оптимальным и быстрым.