stk_sync_cv.h

Go to the documentation of this file.

/*
 * SuperTinyKernel(TM) RTOS: Lightweight High-Performance Deterministic C++ RTOS for Embedded Systems.
 *
 * Source: https://github.com/SuperTinyKernel-RTOS
 *
 * Copyright (c) 2022-2026 Neutron Code Limited <stk@neutroncode.com>. All Rights Reserved.
 * License: MIT License, see LICENSE for a full text.
 */
 
#ifndef STK_SYNC_CV_H_
#define STK_SYNC_CV_H_
 
#include "stk_sync_cs.h"

 
namespace stk {
namespace sync {

class ConditionVariable : private ISyncObject, public ITraceable
{
public:
    explicit ConditionVariable()
    {}

    ~ConditionVariable()
    {
        STK_ASSERT(m_wait_list.IsEmpty()); // API contract: must not be destroyed with waiting tasks
    }

    bool Wait(IMutex &mutex, Timeout timeout = WAIT_INFINITE);

    void NotifyOne();

    void NotifyAll();
 
private:
    STK_NONCOPYABLE_CLASS(ConditionVariable);
};
 
// ---------------------------------------------------------------------------
// Wait
// ---------------------------------------------------------------------------
 
inline bool ConditionVariable::Wait(IMutex &mutex, Timeout timeout)
{
    // API contract: mutex must be locked by the calling task before Wait() is called.
    // The kernel releases it atomically during suspension and re-acquires it on wake.
 
    if (timeout == NO_WAIT)
        return false;
 
    STK_ASSERT(!hw::IsInsideISR()); // API contract: caller must not be in ISR if timeout!=NO_WAIT
 
    return !IKernelService::GetInstance()->Wait(this, &mutex, timeout)->IsTimeout();
}
 
// ---------------------------------------------------------------------------
// NotifyOne
// ---------------------------------------------------------------------------
 
inline void ConditionVariable::NotifyOne()
{
    ScopedCriticalSection cs_;
    WakeOne(); // wakes the first task in the wait list (FIFO order), if any
}
 
// ---------------------------------------------------------------------------
// NotifyAll
// ---------------------------------------------------------------------------
 
inline void ConditionVariable::NotifyAll()
{
    ScopedCriticalSection cs_;
    WakeAll(); // wakes all tasks in the wait list simultaneously
}
 
} // namespace sync
} // namespace stk
 
#endif /* STK_SYNC_CV_H_ */