ThreadLock.h

Go to the documentation of this file.

 
#ifndef HELPERS_THREADLOCK_INC_THREADLOCK_H_
#define HELPERS_THREADLOCK_INC_THREADLOCK_H_
 
#ifndef SIMULATION
#include <wirish.h>
#endif // !SIMULATION
#include <functional>
 
#define TLock(lockObj) for(std::function<void(void)> func = nullptr; func == nullptr; (lockObj).DoLocked(func)) func = [&]()
 
#define TLockS(lockObj, ret) for(std::function<void(void)> func = nullptr; func == nullptr; (ret) = (lockObj).DoLocked(func)) func = [&]()
 
#define TLWhenUnlockedS(lockObj, ret) for(__magic_lock_raii rrrrr___(&(lockObj), (ret)); !rrrrr___.lck; rrrrr___.lck = true)
 
#define TLWhenUnlocked(lockObj) for(__magic_lock_raii rrrrr___(&(lockObj)); !rrrrr___.lck; rrrrr___.lck = true)
 
#define THREAD_LOCK_FUNC_BUFF_SIZE (5) //Size of function buffer (max count of interrupts when locked)
 
class ThreadLock{
public:
    ThreadLock():
        lock(false),
        funcBufferCnt(0)
    {
 
    }
    bool DoLocked(std::function<void(void)> func);
 
    inline volatile bool isLocked(){
        return lock;
    }
 
    bool Lock();
    bool Unlock();
 
protected:
    bool LockPriv();
 
    uint32_t UnlockPriv(uint32_t prim);
 
    volatile bool lock:1;
    volatile uint8_t funcBufferCnt:5;
    std::function<void(void)> funcBuffer [THREAD_LOCK_FUNC_BUFF_SIZE] = {nullptr};
};
 
class __magic_lock_raii{
public:
    __magic_lock_raii(ThreadLock *_lockObj, bool &lockStatus){
        lockObj = _lockObj;
        lck_stat = lockStatus = _lockObj->Lock();
        lck = !lck_stat;
    }
 
    __magic_lock_raii(ThreadLock *_lockObj){
        lockObj = _lockObj;
        lck_stat = _lockObj->Lock();
        lck = !lck_stat;
    }
 
    bool lck = false;
 
    ThreadLock* lockObj;
 
    ~__magic_lock_raii(){
        if(lck_stat) lockObj->Unlock();
    }
private:
    bool lck_stat;
};
 
#endif /* HELPERS_THREADLOCK_INC_THREADLOCK_H_ */