csander/EventManagementSystem
1
0
Fork 0
forked from byterazor/EventManager
Code Issues Pull Requests Projects Releases Wiki Activity

ADD: check for timeout when waiting for event

Browse Source
This commit is contained in:
Dominik Meyer 2021-08-16 20:12:05 +02:00
parent 789ce929a4
commit e7b1eeeaa1
No known key found for this signature in database
GPG Key ID: B4C312B600606B64
2 changed files with 13 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
include/EventManager/Participant.hpp
View File

@ -102,8 +102,11 @@
/** /**
* @brief wait for a new event with timeout * @brief wait for a new event with timeout
*
* @return true - new event available and queue locked
* @return false - no new event, queue not locked, timeout reached
*/ */
void _waitForEvent(std::uint32_t timeoutMS); bool _waitForEvent(std::uint32_t timeoutMS);
/** /**
* @brief This method subscribes the participant to an event type * @brief This method subscribes the participant to an event type

10
src/EventManager/Participant.cpp
View File

@ -94,11 +94,17 @@ void EventManager::Participant::_waitForEvent()
isQueueLocked_=true; isQueueLocked_=true;
} }
void EventManager::Participant::_waitForEvent(std::uint32_t timeoutMS) bool EventManager::Participant::_waitForEvent(std::uint32_t timeoutMS)
{ {
std::unique_lock<std::mutex> lock(mutexEventQueue_); std::unique_lock<std::mutex> lock(mutexEventQueue_);
newEventInQueue_.wait_for(lock,timeoutMS*1ms); if (newEventInQueue_.wait_for(lock,timeoutMS*1ms)==std::cv_status::no_timeout)
{
isQueueLocked_=true; isQueueLocked_=true;
return true;
}
return false;
} }