Mirrors/overte
3
0
Fork 0
mirror of https://github.com/overte-org/overte.git synced 2025-08-10 12:12:32 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

Remove lockFor... and expand ReadWriteLockable

Browse source
This commit is contained in:
Atlante45 2015-11-10 18:19:12 -08:00
parent 3557eacbd0
commit 7cf2ad2215
1 changed files with 100 additions and 36 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

132
libraries/shared/src/shared/ReadWriteLockable.h
View file

@ -9,54 +9,118 @@
#pragma once #pragma once
#ifndef hifi_ReadWriteLockable_h #ifndef hifi_ReadWriteLockable_h
#define hifi_ReadWriteLockable_h #define hifi_ReadWriteLockable_h
#include <utility>
#include <QtCore/QReadWriteLock> #include <QtCore/QReadWriteLock>
#include "QTryReadLocker.h"
#include "QTryWriteLocker.h"
class ReadWriteLockable { class ReadWriteLockable {
public: public:
// Write locks
template <typename F> template <typename F>
bool withWriteLock(F f, bool require = true) const { bool withWriteLock(F f) const;
if (!require) {
bool result = _lock.tryLockForWrite();
if (result) {
f();
_lock.unlock();
}
return result;
}
QWriteLocker locker(&_lock);
f();
return true;
}
template <typename F> template <typename F>
bool withTryWriteLock(F f) const { bool withWriteLock(F&& f, bool require) const;
return withWriteLock(f, false);
}
template <typename F> template <typename F>
bool withReadLock(F f, bool require = true) const { bool withTryWriteLock(F f) const;
if (!require) {
bool result = _lock.tryLockForRead();
if (result) {
f();
_lock.unlock();
}
return result;
}
QReadLocker locker(&_lock);
f();
return true;
}
template <typename F> template <typename F>
bool withTryReadLock(F f) const { bool withTryWriteLock(F f, int timeout) const;
return withReadLock(f, false);
} // Read locks
template <typename F>
bool withReadLock(F f) const;
template <typename F>
bool withReadLock(F&& f, bool require) const;
template <typename F>
bool withTryReadLock(F f) const;
template <typename F>
bool withTryReadLock(F f, int timeout) const;
private: private:
mutable QReadWriteLock _lock{ QReadWriteLock::Recursive }; mutable QReadWriteLock _lock{ QReadWriteLock::Recursive };
}; };
// ReadWriteLockable
template <typename F>
inline bool ReadWriteLockable::withWriteLock(F f) const {
QWriteLocker locker(&_lock);
f();
return true;
}
template <typename F>
inline bool ReadWriteLockable::withWriteLock(F&& f, bool require) const {
if (require) {
return withWriteLock(std::forward<F>(f));
} else {
return withTryReadLock(std::forward<F>(f));
}
}
template <typename F>
inline bool ReadWriteLockable::withTryWriteLock(F f) const {
QTryWriteLocker locker(&_lock);
if (locker.isLocked()) {
f();
return true;
}
return false;
}
template <typename F>
inline bool ReadWriteLockable::withTryWriteLock(F f, int timeout) const {
QTryWriteLocker locker(&_lock, timeout);
if (locker.isLocked()) {
f();
return true;
}
return false;
}
template <typename F>
inline bool ReadWriteLockable::withReadLock(F f) const {
QReadLocker locker(&_lock);
f();
return true;
}
template <typename F>
inline bool ReadWriteLockable::withReadLock(F&& f, bool require) const {
if (require) {
return withReadLock(std::forward<F>(f));
} else {
return withTryReadLock(std::forward<F>(f));
}
}
template <typename F>
inline bool ReadWriteLockable::withTryReadLock(F f) const {
QTryReadLocker locker(&_lock);
if (locker.isLocked()) {
f();
return true;
}
return false;
}
template <typename F>
inline bool ReadWriteLockable::withTryReadLock(F f, int timeout) const {
QTryReadLocker locker(&_lock, timeout);
if (locker.isLocked()) {
f();
return true;
}
return false;
}
#endif #endif