다음을 통해 공유

overwrite_buffer 클래스

  • 아티클

overwrite_buffer 메시징 블록은 한 번에 하나의 메시지를 저장할 수 있는, 순서가 지정된 다중 대상 다중 소스 propagator_block입니다. 새 메시지가 이전에 보유한 메시지를 덮어씁니다.

구문

template<class T>
class overwrite_buffer : public propagator_block<multi_link_registry<ITarget<T>>, multi_link_registry<ISource<T>>>;

매개 변수

T
버퍼에 의해 저장되고 전파되는 메시지의 페이로드 형식입니다.

멤버

공용 생성자

속성 설명
overwrite_buffer 오버로드됨. 메시징 블록을 생성합니다 overwrite_buffer .
~overwrite_buffer 소멸자 메시징 블록을 삭제합니다 overwrite_buffer .

공용 메서드

이름 설명
has_value 이 overwrite_buffer 메시징 블록에 아직 값이 있는지 확인합니다.
value 메시징 블록에 저장되는 메시지의 현재 페이로드에 대한 참조를 overwrite_buffer 가져옵니다.

보호된 메서드

속성 설명
accept_message 이 overwrite_buffer 메시징 블록에서 제공한 메시지를 수락하고 메시지 복사본을 호출자에게 반환합니다.
consume_message 이전에 메시징 블록에서 overwrite_buffer 제공하고 대상에서 예약한 메시지를 사용하여 메시지 복사본을 호출자에게 반환합니다.
link_target_notification 새 대상이 이 overwrite_buffer 메시징 블록에 연결되었음을 나타내는 콜백입니다.
propagate_message 블록에서 ISource 이 overwrite_buffer 메시징 블록으로 메시지를 비동기적으로 전달합니다. 소스 블록에서 호출할 propagate 때 메서드에 의해 호출됩니다.
propagate_to_any_targets message _PMessage 이 overwrite_buffer 메시징 블록에 배치하고 연결된 모든 대상에 제공합니다.
release_message 이전 메시지 예약을 해제합니다. (source_block::release_message 재정의)
reserve_message 이 overwrite_buffer 메시징 블록에서 이전에 제공한 메시지를 예약합니다. (source_block::reserve_message 재정의)
resume_propagation 예약이 해제된 후 전파를 다시 시작합니다. (source_block::resume_propagation 재정의)
send_message 블록에서 ISource 이 overwrite_buffer 메시징 블록으로 메시지를 동기적으로 전달합니다. 소스 블록에서 호출할 send 때 메서드에 의해 호출됩니다.
supports_anonymous_source supports_anonymous_source 메서드를 재정의하여 이 블록이 연결되지 않은 소스에서 제공하는 메시지를 수락할 수 있음을 나타냅니다. (재정의 ITarget::supports_anonymous_source.)

설명

메시징 블록은 overwrite_buffer 저장된 메시지의 복사본을 각 대상에 전파합니다.

자세한 내용은 비동기 메시지 블록을 참조 하세요.

상속 계층 구조

ISource

ITarget

source_block

propagator_block

overwrite_buffer

요구 사항

헤더: agents.h

네임스페이스: 동시성

accept_message

이 overwrite_buffer 메시징 블록에서 제공한 메시지를 수락하고 메시지 복사본을 호출자에게 반환합니다.

virtual message<T>* accept_message(runtime_object_identity _MsgId);

매개 변수

_MsgId
runtime_object_identity 제공 message 된 개체의 개체입니다.

Return Value

호출자의 소유권이 message 있는 개체에 대한 포인터입니다.

설명

메시징 블록은 overwrite_buffer 현재 보유된 메시지의 소유권을 전송하는 대신 대상에 메시지의 복사본을 반환합니다.

consume_message

이전에 메시징 블록에서 overwrite_buffer 제공하고 대상에서 예약한 메시지를 사용하여 메시지 복사본을 호출자에게 반환합니다.

virtual message<T>* consume_message(runtime_object_identity _MsgId);

매개 변수

_MsgId
runtime_object_identity 사용 중인 개체의 message 개체입니다.

Return Value

호출자의 소유권이 message 있는 개체에 대한 포인터입니다.

설명

은 accept유사하지만 항상 호출 앞에 있습니다 reserve.

has_value

이 overwrite_buffer 메시징 블록에 아직 값이 있는지 확인합니다.

bool has_value() const;

Return Value

true 블록이 값을 false 수신하면 그렇지 않습니다.

새 대상이 이 overwrite_buffer 메시징 블록에 연결되었음을 나타내는 콜백입니다.

virtual void link_target_notification(_Inout_ ITarget<T>* _PTarget);

매개 변수

_PTarget
새로 연결된 대상에 대한 포인터입니다.

~overwrite_buffer

메시징 블록을 삭제합니다 overwrite_buffer .

~overwrite_buffer();

overwrite_buffer

메시징 블록을 생성합니다 overwrite_buffer .

overwrite_buffer();

overwrite_buffer(
    filter_method const& _Filter);

overwrite_buffer(
    Scheduler& _PScheduler);

overwrite_buffer(
    Scheduler& _PScheduler,
    filter_method const& _Filter);

overwrite_buffer(
    ScheduleGroup& _PScheduleGroup);

overwrite_buffer(
    ScheduleGroup& _PScheduleGroup,
    filter_method const& _Filter);

매개 변수

_필터
제공된 메시지를 수락해야 하는지 여부를 결정하는 필터 함수입니다.

_PScheduler
Scheduler 메시징 블록의 전파 작업이 예약되는 overwrite_buffer 개체입니다.

_PScheduleGroup
ScheduleGroup 메시징 블록의 전파 작업이 예약되는 overwrite_buffer 개체입니다. 사용된 Scheduler 개체는 일정 그룹에서 암시됩니다.

설명

런타임은 _PScheduler 또는 _PScheduleGroup 매개 변수를 지정하지 않는 경우 기본 스케줄러를 사용합니다.

이 형식 filter_method 은 제공된 메시지를 수락해야 하는지 여부를 결정하기 위해 이 overwrite_buffer 메시징 블록에서 호출하는 서명 bool (T const &) 이 있는 functor입니다.

propagate_message

블록에서 ISource 이 overwrite_buffer 메시징 블록으로 메시지를 비동기적으로 전달합니다. 소스 블록에서 호출할 propagate 때 메서드에 의해 호출됩니다.

virtual message_status propagate_message(
    _Inout_ message<T>* _PMessage,
    _Inout_ ISource<T>* _PSource);

매개 변수

_PMessage
message 개체에 대한 포인터입니다.

_PSource
메시지를 제공하는 소스 블록에 대한 포인터입니다.

Return Value

대상이 메시지로 무엇을 하기로 결정했는지에 대한 message_status 표시입니다.

propagate_to_any_targets

message _PMessage 이 overwrite_buffer 메시징 블록에 배치하고 연결된 모든 대상에 제공합니다.

virtual void propagate_to_any_targets(_Inout_ message<T>* _PMessage);

매개 변수

_PMessage
소유권을 가져온 개체 overwrite_buffer 에 대한 message 포인터입니다.

설명

이 메서드는 새로 수락된 메시지를 overwrite_buffer 사용하여 현재 메시지를 _PMessage덮어씁니다.

send_message

블록에서 ISource 이 overwrite_buffer 메시징 블록으로 메시지를 동기적으로 전달합니다. 소스 블록에서 호출할 send 때 메서드에 의해 호출됩니다.

virtual message_status send_message(
    _Inout_ message<T>* _PMessage,
    _Inout_ ISource<T>* _PSource);

매개 변수

_PMessage
message 개체에 대한 포인터입니다.

_PSource
메시지를 제공하는 소스 블록에 대한 포인터입니다.

Return Value

대상이 메시지로 무엇을 하기로 결정했는지에 대한 message_status 표시입니다.

supports_anonymous_source

supports_anonymous_source 메서드를 재정의하여 이 블록이 연결되지 않은 소스에서 제공하는 메시지를 수락할 수 있음을 나타냅니다.

virtual bool supports_anonymous_source();

Return Value

true 블록이 제공된 메시지를 연기하지 않기 때문입니다.

release_message

이전 메시지 예약을 해제합니다.

virtual void release_message(runtime_object_identity _MsgId);

매개 변수

_MsgId
runtime_object_identity 해제되는 개체의 message 수입니다.

reserve_message

이 overwrite_buffer 메시징 블록에서 이전에 제공한 메시지를 예약합니다.

virtual bool reserve_message(runtime_object_identity _MsgId);

매개 변수

_MsgId
runtime_object_identity 예약 중인 개체의 message 개체입니다.

Return Value

true 메시지가 성공적으로 예약 false 되었으면 그렇지 않습니다.

설명

호출된 후 reserve 반환 trueconsume 되는 경우 메시지의 소유권을 취하거나 release 해제하기 위해 호출해야 합니다.

resume_propagation

예약이 해제된 후 전파를 다시 시작합니다.

virtual void resume_propagation();

value

메시징 블록에 저장되는 메시지의 현재 페이로드에 대한 참조를 overwrite_buffer 가져옵니다.

T value();

Return Value

현재 저장된 메시지의 페이로드입니다.

설명

이 메서드가 반환된 직후에 overwrite_buffer 저장된 값이 변경될 수 있습니다. 이 메서드는 현재 에 저장되어 overwrite_buffer있는 메시지가 없는 경우 메시지가 도착할 때까지 대기합니다.

참고 항목

concurrency 네임스페이스
unbounded_buffer 클래스
single_assignment 클래스