Читать «UNIX: взаимодействие процессов» онлайн - страница 65
Уильям Ричард Стивенс
solaris % mqsend /test1 33 18
solaris % mqreceive /test1
read 50 bytes, priority = 18
solaris % mqreceive /test1
read 33 bytes, priority = 18
Solaris % mqreceive /test1
read 100 bytes, priority = 6
Solaris % mqreceive –n /test1
mq_receive error: Resource temporarily unavailable
Мы видим, что mq_receive действительно возвращает старейшее сообщение с наивысшим приоритетом.
5.5. Ограничения очередей сообщений
Мы уже сталкивались с двумя ограничениями, устанавливаемыми для любой очереди в момент ее создания:
■ mq_maxmsg — максимальное количество сообщений в очереди;
■ mq_msgsize — максимальный размер сообщения.
Не существует каких-либо ограничений на эти значения, хотя в рассматриваемых реализациях необходимо наличие в файловой системе места для файла требуемого размера. Кроме того, ограничения на эти величины могут накладываться реализацией виртуальной памяти (см. упражнение 5.5).
Другие два ограничения определяются реализацией:
■ MQ_OPEN_MAX — максимальное количество очередей сообщений, которые могут быть одновременно открыты каким-либо процессом (Posix требует, чтобы эта величина была не меньше 8);
■ MQ_PRIO_MAX — максимальное значение приоритета плюс один (Posix требует, чтобы эта величина была не меньше 32).
Эти две константы часто определяются в заголовочном файле <unistd.h> и могут быть получены во время выполнения программы вызовом функции sysconf, как мы покажем далее.
Пример: программа mqsysconf
Программа в листинге 5.7 вызывает функцию sysconf и выводит два ограничения на очереди сообщений, определяемые реализацией.
Листинг 5.7. Получение ограничений очередей с помощью sysconf
//pxmsg/mqsysconf.с
1 #include "unpipc.h"
2 int
3 main(int argc, char **argv)
4 {
5 printf("MQ_OPEN_MAX = %ld, MQ_PRIO_MAX = %ld\n",
6 Sysconf(_SC_MQ_OPEN_MAX), Sysconf(_SC_MQ_PRIO_MAX));
7 exit(0);
8 }
Запустив эту программу в наших двух операционных системах, получим:
solaris % mqsysconf
MQ_OPEN_MAX = 32, MQ_PRIO_MAX = 32
alpha % mqsysconf
MQ_OPEN_MAX = 64, MQ_PRIO_MAX = 256
5.6. Функция mq_notify
Один из недостатков очередей сообщений System V, как мы увидим в главе 6, заключается в невозможности уведомить процесс о том, что в очередь было помещено сообщение. Мы можем заблокировать процесс при вызове msgrcv, но тогда мы не сможем выполнять другие действия во время ожидания сообщения. Если мы укажем флаг отключения блокировки при вызове msgrcv (IPC_NOWAIT), процесс не будет заблокирован, но нам придется регулярно вызывать эту функцию, чтобы получить сообщение, когда оно будет отправлено. Мы уже говорили, что такая процедура называется
ПРИМЕЧАНИЕ
В этом и всех последующих разделах данной главы обсуждаются более сложные вопросы, которые могут быть пропущены при первом чтении.
