GuardWithTimeout.h

#ifndef TENDUKE_CONCURRENT_GUARDWITHTIMEOUT_H
#define TENDUKE_CONCURRENT_GUARDWITHTIMEOUT_H
 
#include <mutex>
#include <cstdint>
#include <chrono>
 
namespace tenduke { namespace concurrent {
 
template <typename TIMED_MUTEX>
class GuardWithTimeout
{
public:
    GuardWithTimeout(TIMED_MUTEX &mutex, std::chrono::milliseconds timeout)
    : mutex(mutex), timedout(false)
    {
        if (!mutex.try_lock_for(timeout)) {
            timedout = true;
        }
    }
 
    virtual ~GuardWithTimeout()
    {
        if (!timedout) {
            mutex.unlock();
        }
    }
 
    bool hasTimedout() const
    {
        return timedout;
    }
 
private:
    TIMED_MUTEX &mutex;
    bool timedout;
};
 
typedef GuardWithTimeout<std::recursive_timed_mutex> RecursiveGuardWithTimeout;
 
}}
 
#endif //TENDUKE_CONCURRENT_GUARDWITHTIMEOUT_H