#include <status_monitor.h>
Public Member Functions | |
void | addStatusMonitor (std::shared_ptr< StatusMonitor > &status_monitor) |
MultiStatusConditionMonitor () | |
~MultiStatusConditionMonitor () override=default | |
Public Member Functions inherited from Aws::DataFlow::ThreadMonitor | |
void | notify () |
void | waitForWork () |
std::cv_status | waitForWork (const std::chrono::microseconds &duration) |
virtual | ~ThreadMonitor ()=default |
Protected Member Functions | |
bool | hasWork () override |
virtual void | setStatus (const Status &status, StatusMonitor *status_monitor) |
Protected Attributes | |
std::atomic< uint64_t > | mask_ {} |
MaskFactory | mask_factory_ |
std::unordered_map< StatusMonitor *, uint64_t > | status_monitors_ |
friend | StatusMonitor |
Multi Status Condition Monitor listens to N StatusMonitors and determines whether to trigger wait for work based on the hasWork() function.
Definition at line 116 of file status_monitor.h.
|
inline |
Definition at line 118 of file status_monitor.h.
|
overridedefault |
void Aws::DataFlow::MultiStatusConditionMonitor::addStatusMonitor | ( | std::shared_ptr< StatusMonitor > & | status_monitor | ) |
Definition at line 53 of file status_monitor.cpp.
|
overrideprotectedvirtual |
Implements Aws::DataFlow::ThreadMonitor.
Definition at line 73 of file status_monitor.cpp.
|
protectedvirtual |
Definition at line 63 of file status_monitor.cpp.
|
protected |
Definition at line 128 of file status_monitor.h.
|
protected |
Definition at line 127 of file status_monitor.h.
|
protected |
Definition at line 129 of file status_monitor.h.
|
protected |
Definition at line 124 of file status_monitor.h.