diff --git a/emper/UnboundedBlockingMpscQueue.hpp b/emper/UnboundedBlockingMpscQueue.hpp index 6cdff408bd41ae1a24b41e6c840f8c3b6f18e686..5b2c8534b212fe41b53f4726405503a3a8f2a2b1 100644 --- a/emper/UnboundedBlockingMpscQueue.hpp +++ b/emper/UnboundedBlockingMpscQueue.hpp @@ -54,7 +54,7 @@ class UnboundedBlockingMpscQueue : public Blockable<LogSubsystem::U_B_MPSC_Q> { // Micro optimization, see if there is a blocked context // before performing the atomic exchange operation. - if (blockedContext.load() != nullptr) { + if (blockedContext != nullptr) { tryToWakeupBlockedContext<callerEnvironment>(); } }