Класс unbounded_buffer
Блок обмена сообщениями unbounded_buffer multi-целевой объект, multi-источник, заказанное количество сообщений propagator_block, способное хранения unbounded.
template<
class _Type
>
class unbounded_buffer : public propagator_block<multi_link_registry<ITarget<_Type>>, multi_link_registry<ISource<_Type>>>;
Параметры
- _Type
Тип полезных данных сообщения, который хранит и распространимый буфер.
Участники
Открытые конструкторы
Имя |
Описание |
---|---|
Перегружен.Создает блок обмена сообщениями unbounded_buffer. |
|
Уничтожает блок обмена сообщениями unbounded_buffer. |
Открытые методы
Имя |
Описание |
---|---|
Удаляет элемент из блока обмена сообщениями unbounded_buffer. |
|
Добавляет элемент в блоке unbounded_buffer обмена сообщениями. |
Защищенные методы
Имя |
Описание |
---|---|
Принимает сообщение, которое было предложено этим блоком обмена сообщениями unbounded_buffer передавать владение участнику. |
|
Использует сообщение ранее предлагаемое блоком обмена сообщениями unbounded_buffer и зарезервированное целевым объектом передавать владение участнику. |
|
Обратный вызов, который сообщает, что новый целевой объект был связан с этот блок обмена сообщениями unbounded_buffer. |
|
Задает message_PMessage в этом блоке обмена сообщениями unbounded_buffer и пытается рекомендовать его ко всем связанным целевым объектам. |
|
Асинхронно передает сообщения из блока ISource в этот блок обмена сообщениями unbounded_buffer.Вызывается методом propagate, вызывается блоком источника. |
|
Задает message_PMessage в этом блоке обмена сообщениями unbounded_buffer и пытается рекомендовать его ко всем связанным целевым объектам.Переопределяет source_block::propagate_output_messages(). |
|
Выпуски предыдущее резервирование сообщения.Переопределяет source_block::release_message(). |
|
Резервирует сообщение ранее предлагаемое этим блоком обмена сообщениями unbounded_buffer.Переопределяет source_block::reserve_message(). |
|
Возобновляет распространение после резервирование было освобождено.Переопределяет source_block::resume_propagation(). |
|
Одновременно передает сообщения из блока ISource в этот блок обмена сообщениями unbounded_buffer.Вызывается методом send, вызывается блоком источника. |
|
Переопределяет метод supports_anonymous_source, чтобы показать, что этот блок сообщений может принять предлагаемые к нему источника, который не связан.Переопределяет ITarget::supports_anonymous_source(). |
Заметки
Дополнительные сведения см. в разделе Асинхронные блоки сообщений.
Иерархия наследования
unbounded_buffer
Требования
заголовок: agents.h
Параллелизм пространство имен: