Используйте блок очереди, чтобы управлять сообщениями

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

Управляйте переходами сообщения Используя очередь, сортирующую политики

Блок Queue поддерживает три сообщения, сортирующие политики:

В обратном порядке (FIFO) — новейшее сообщение в устройстве хранения данных отбывает сначала.

Метод "первым пришел - первым вышел" (FIFO) — самое старое сообщение в устройстве хранения данных отбывает сначала.

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

Этот пример использует простую основанную на сообщении коммуникационную модель, которая введена в, Визуализируют, Анимируют и Смотрят сообщения. Модель включает Поток сообщений 1 и Поток сообщений 2, в котором сообщения текут из Синуса Wave1 к Scope1 и Синусу Wave2 к Scope2.

Описание модели

В потоке сообщений 1 и потоке сообщений 2:

Параметр Шага расчета Синуса Wave1 и Синус Wave2 устанавливается на 0.1. Они - идентичные источники синусоиды.

Параметр Шага расчета Receive1 и Receive2 устанавливается на 0.5. Они идентичны, Получают блоки.

Способностью Queue1 и Queue2 является 100. У обеих очередей есть та же способность.

Политикой сортировки Queue1 является LIFO и Queue2 является FIFO, который отображен под марками блока. Единственной разницей между двумя сценариями потока сообщений является очередь, сортирующая политику.

Сигналы среди Синуса Wave1, Receive1 и Receive2 регистрируются.

Симулируйте модель и рассмотрите результаты

Симулируйте модель и наблюдайте результаты в Инспекторе Данных моделирования.

Наблюдайте выходной сигнал от Синуса Wave1. Вывод от SineWave2 не отображен, потому что это идентично SineWave1. Также заметьте, что сигнал от Receive1 является представлением синусоиды, но с более длинными интервалами между выборками. Однако сигнал от Receive2 является первой частью синусоиды, достигающей к положительному пику, потому что политика сортировки блока Queue установлена в FIFO и его способность является достаточно большой, чтобы хранить сообщения.

Групповое сообщение очереди, перезаписывающее политики

Можно также задать групповое сообщение Очереди, перезаписывающее политику, когда очередь полна:

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

В этом примере поведения очереди сообщения перечисляются на основе их времени поступления в FIFO и очередях LIFO со способностью 8. Новое сообщение с номером 9 прибывает. В FIFO и случаях LIFO, передайте 9 сообщение 1 замен, потому что это - самый старый элемент в очереди. Однако наблюдайте изменение головы и хвоста очереди во время этого процесса. В очереди FIFO передайте 2 отбывает сначала, потому что это - самое старое сообщение после сообщения 1 заменяется. В очереди LIFO передайте 9 отбывает сначала, потому что это - последнее сообщение, которое прибывает в устройство хранения данных. После отъезда сообщения, новое сообщение 10 прибывает. Очередь принимает новые сообщения к своему пустому интервалу устройства хранения данных.

Если Перезапись, самый старый элемент, если очередь является полным флажком, очищен, значок изменений блока Queue и блока, не принимает новые сообщения, когда очередь полна. Это - блокирующееся поведение очереди.

Блок очереди с перезаписью Enabled политики

В модели QueueSortingPoliciesModelSequenceViewer мощности блоков Очереди в Потоке сообщений 1 и Потоке сообщений 2 изменяются на 15. Уменьшение способности заставляет входящие сообщения перезаписывать существующие единицы в устройстве хранения данных.

Симулируйте модель и откройте блок Sequence Viewer. В блоке Sequence Viewer прокрутите или нажмите Go к первому значку события слева. Наблюдайте сообщения, отбывая из блока на основе политик LIFO и FIFO.

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

Пример блокирующегося поведения очереди

Откройте QueueOverWritingPolicyModel, чтобы смотреть блокирующееся поведение очереди.

В блоке Receive, установленном параметр Шага расчета на 0.5.

Заметьте что в блоке Queue:

Перезапись самый старый элемент, если очередь является полным флажком, очищена. Наблюдайте изменение значка блока.

Полный параметр устанавливается на 16.

Во вкладке Statistics выбраны Количество сущностей, из которых отбывают, d и Количество сущностей в блоке, n флажки.

Симулируйте модель и рассмотрите результаты

Симулируйте модель. Наблюдайте предупреждение, выведенное в Диагностическом Средстве просмотра. Сообщения, отправленные блоком Send, были пропущены в процессе моделирования.

Блок Queue блокирует сообщения, когда Перезапись самый старый элемент, если очередь является полным флажком, очищена. Можно увеличить возможность блока Queue предотвратить сбрасывание донесений.

Используйте статистику, чтобы анализировать поведение очереди

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

Заметьте, что сигналы пометили Number of Messages in Block и Number of Messages Departed. До времени симуляции 2, существует 16 сообщения в устройстве хранения данных, которое является способностью очереди. После этого Количество сообщений в Блоке принимает значения 15 и 16 потому что сообщения отбывают из каждого 0.5 время симуляции и новое сообщение прибывают.

Во времени симуляции 10, в общей сложности 21 сообщения отбывают из блока.

Используйте действия события

Можно также использовать действия События, когда Перезапись самый старый элемент, если очередь является полным флажком, очищена. Действия события не поддержаны для генерации кода.

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

Для получения дополнительной информации смотрите Запуск На основе Доступности данных сообщения.

Можно также смоделировать более комплексные коммуникационные политики при помощи блоков из библиотеки SimEvents®, которая требует лицензии SimEvents®.

Документация