Теперь рассмотрим третье и последнее средство System V IPC: очереди сообщений. Во многом очереди сообщений похожи на именованные каналы, но без сложностей, сопровождающих открытие и закрытие канала. Однако применение очереди сообщений не избавляет вас от проблем, возникающих при использовании именованных каналов, например блокировки заполненных каналов.

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

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

Наложив эти ограничения, стандарт X/Open не позаботился о способе выяснения их числовых значений за исключением того, что превышение ограничений — достаточное основание для аварийного завершения функций обработки очереди сообщений. В ОС Linux есть два определения:

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

Далее приведены объявления функций для работы с очередями сообщений:

Как и в случае семафоров или совместно используемой памяти, заголовочные файлы sys/types.h и sys/ipc.h обычно автоматически включаются заголовочным файлом msg.h.

Очередь сообщений создается и предоставляет к себе доступ с помощью функции

:

Программа должна предоставить значение параметра

, которое, как и в других средствах IPC, задает имя конкретной очереди сообщений. С помощью специального значения создается скрытая или частная очередь, которая теоретически доступна только текущему процессу. Как и в случае семафоров и совместно используемой памяти, в некоторых системах Linux такая очередь может не быть частной. Поскольку от скрытой или частной очереди очень мало пользы, это не слишком важная проблема. Как и раньше, второй параметр состоит из девяти флагов прав доступа. Для создания новой очереди сообщений специальный бит со значением должен быть объединен с правами доступа поразрядной операцией . Не считается ошибкой установка флага и задание ключа уже существующей очереди сообщений. Если очередь уже есть, флаг безмолвно игнорируется.

Функция

вернет положительное число, идентификатор очереди; в случае успешного завершения и -1 в случае сбоя.

Функция

позволяет добавить сообщение в очередь сообщений:

Структура сообщения ограничена двумя способами. Во-первых, она должна быть меньше системного ограничения, и во-вторых, она должна начинаться с элемента типа

, который будет использован как тип сообщения в получающей функции. Если вы применяете сообщения, лучше всего определить структуру сообщения следующим образом.

Поскольку элемент

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

Первый параметр

— идентификатор очереди сообщений, возвращаемый функцией .

Второй параметр

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

Третий параметр

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

Четвертый параметр

управляет действиями, предпринимаемыми при заполнении текущей очереди сообщений или достижении общесистемного ограничения для очередей сообщений. Если в параметре установлен флаг , функция вернет управление немедленно без отправки сообщения и возвращаемое значение будет равно -1. Если в параметре флаг сброшен, процесс отправки будет приостановлен в ожидании освобождения доступного объема в очереди.