qreadwritelock.h
上传用户:detong
上传日期:2022-06-22
资源大小:20675k
文件大小:6k
源码类别:

系统编程

开发平台:

Unix_Linux

  1. /****************************************************************************
  2. **
  3. ** Copyright (C) 2008 Nokia Corporation and/or its subsidiary(-ies).
  4. ** Contact: Qt Software Information (qt-info@nokia.com)
  5. **
  6. ** This file is part of the QtCore module of the Qt Toolkit.
  7. **
  8. ** Commercial Usage
  9. ** Licensees holding valid Qt Commercial licenses may use this file in
  10. ** accordance with the Qt Commercial License Agreement provided with the
  11. ** Software or, alternatively, in accordance with the terms contained in
  12. ** a written agreement between you and Nokia.
  13. **
  14. **
  15. ** GNU General Public License Usage
  16. ** Alternatively, this file may be used under the terms of the GNU
  17. ** General Public License versions 2.0 or 3.0 as published by the Free
  18. ** Software Foundation and appearing in the file LICENSE.GPL included in
  19. ** the packaging of this file.  Please review the following information
  20. ** to ensure GNU General Public Licensing requirements will be met:
  21. ** http://www.fsf.org/licensing/licenses/info/GPLv2.html and
  22. ** http://www.gnu.org/copyleft/gpl.html.  In addition, as a special
  23. ** exception, Nokia gives you certain additional rights. These rights
  24. ** are described in the Nokia Qt GPL Exception version 1.3, included in
  25. ** the file GPL_EXCEPTION.txt in this package.
  26. **
  27. ** Qt for Windows(R) Licensees
  28. ** As a special exception, Nokia, as the sole copyright holder for Qt
  29. ** Designer, grants users of the Qt/Eclipse Integration plug-in the
  30. ** right for the Qt/Eclipse Integration to link to functionality
  31. ** provided by Qt Designer and its related libraries.
  32. **
  33. ** If you are unsure which license is appropriate for your use, please
  34. ** contact the sales department at qt-sales@nokia.com.
  35. **
  36. ****************************************************************************/
  37. #ifndef QREADWRITELOCK_H
  38. #define QREADWRITELOCK_H
  39. #include <QtCore/qglobal.h>
  40. #include <limits.h> // ### Qt 5: remove
  41. QT_BEGIN_HEADER
  42. QT_BEGIN_NAMESPACE
  43. QT_MODULE(Core)
  44. #ifndef QT_NO_THREAD
  45. struct QReadWriteLockPrivate;
  46. class Q_CORE_EXPORT QReadWriteLock
  47. {
  48. public:
  49.     enum RecursionMode { NonRecursive, Recursive };
  50.     QReadWriteLock(); // ### Qt 5: merge with below
  51.     QReadWriteLock(RecursionMode recursionMode);
  52.     ~QReadWriteLock();
  53.     void lockForRead();
  54.     bool tryLockForRead();
  55.     bool tryLockForRead(int timeout);
  56.     void lockForWrite();
  57.     bool tryLockForWrite();
  58.     bool tryLockForWrite(int timeout);
  59.     void unlock();
  60. private:
  61.     Q_DISABLE_COPY(QReadWriteLock)
  62.     QReadWriteLockPrivate *d;
  63.     friend class QWaitCondition;
  64. };
  65. #if defined(Q_CC_MSVC)
  66. #pragma warning( push )
  67. #pragma warning( disable : 4312 ) // ignoring the warning from /Wp64
  68. #endif
  69. class Q_CORE_EXPORT QReadLocker
  70. {
  71. public:
  72.     inline QReadLocker(QReadWriteLock *readWriteLock);
  73.     inline ~QReadLocker()
  74.     { unlock(); }
  75.     inline void unlock()
  76.     {
  77.         if (q_lock) {
  78.             if ((q_val & quintptr(1u)) == quintptr(1u)) {
  79.                 q_val &= ~quintptr(1u);
  80.                 q_lock->unlock();
  81.             }
  82.         }
  83.     }
  84.     inline void relock()
  85.     {
  86.         if (q_lock) {
  87.             if ((q_val & quintptr(1u)) == quintptr(0u)) {
  88.                 q_lock->lockForRead();
  89.                 q_val |= quintptr(1u);
  90.             }
  91.         }
  92.     }
  93.     inline QReadWriteLock *readWriteLock() const
  94.     { return reinterpret_cast<QReadWriteLock *>(q_val & ~quintptr(1u)); }
  95. private:
  96.     Q_DISABLE_COPY(QReadLocker)
  97.     union {
  98.         QReadWriteLock *q_lock;
  99.         quintptr q_val;
  100.     };
  101. };
  102. inline QReadLocker::QReadLocker(QReadWriteLock *areadWriteLock)
  103.     : q_lock(areadWriteLock)
  104. {
  105.     Q_ASSERT_X((q_val & quintptr(1u)) == quintptr(0),
  106.                "QReadLocker", "QReadWriteLock pointer is misaligned");
  107.     relock();
  108. }
  109. class Q_CORE_EXPORT QWriteLocker
  110. {
  111. public:
  112.     inline QWriteLocker(QReadWriteLock *readWriteLock);
  113.     inline ~QWriteLocker()
  114.     { unlock(); }
  115.     inline void unlock()
  116.     {
  117.         if (q_lock) {
  118.             if ((q_val & quintptr(1u)) == quintptr(1u)) {
  119.                 q_val &= ~quintptr(1u);
  120.                 q_lock->unlock();
  121.             }
  122.         }
  123.     }
  124.     inline void relock()
  125.     {
  126.         if (q_lock) {
  127.             if ((q_val & quintptr(1u)) == quintptr(0u)) {
  128.                 q_lock->lockForWrite();
  129.                 q_val |= quintptr(1u);
  130.             }
  131.         }
  132.     }
  133.     inline QReadWriteLock *readWriteLock() const
  134.     { return reinterpret_cast<QReadWriteLock *>(q_val & ~quintptr(1u)); }
  135. private:
  136.     Q_DISABLE_COPY(QWriteLocker)
  137.     union{
  138.         QReadWriteLock *q_lock;
  139.         quintptr q_val;
  140.     };
  141. };
  142. inline QWriteLocker::QWriteLocker(QReadWriteLock *areadWriteLock)
  143.     : q_lock(areadWriteLock)
  144. {
  145.     Q_ASSERT_X((q_val & quintptr(1u)) == quintptr(0),
  146.                "QWriteLocker", "QReadWriteLock pointer is misaligned");
  147.     relock();
  148. }
  149. #if defined(Q_CC_MSVC)
  150. #pragma warning( pop )
  151. #endif
  152. #else // QT_NO_THREAD
  153. class Q_CORE_EXPORT QReadWriteLock
  154. {
  155. public:
  156.     inline explicit QReadWriteLock() { }
  157.     inline ~QReadWriteLock() { }
  158.     static inline void lockForRead() { }
  159.     static inline bool tryLockForRead() { return true; }
  160.     static inline bool tryLockForRead(int timeout) { Q_UNUSED(timeout); return true; }
  161.     static inline void lockForWrite() { }
  162.     static inline bool tryLockForWrite() { return true; }
  163.     static inline bool tryLockForWrite(int timeout) { Q_UNUSED(timeout); return true; }
  164.     static inline void unlock() { }
  165. private:
  166.     Q_DISABLE_COPY(QReadWriteLock)
  167. };
  168. class Q_CORE_EXPORT QReadLocker
  169. {
  170. public:
  171.     inline QReadLocker(QReadWriteLock *) { }
  172.     inline ~QReadLocker() { }
  173.     static inline void unlock() { }
  174.     static inline void relock() { }
  175.     static inline QReadWriteLock *readWriteLock() { return 0; }
  176. private:
  177.     Q_DISABLE_COPY(QReadLocker)
  178. };
  179. class Q_CORE_EXPORT QWriteLocker
  180. {
  181. public:
  182.     inline explicit QWriteLocker(QReadWriteLock *) { }
  183.     inline ~QWriteLocker() { }
  184.     static inline void unlock() { }
  185.     static inline void relock() { }
  186.     static inline QReadWriteLock *readWriteLock() { return 0; }
  187. private:
  188.     Q_DISABLE_COPY(QWriteLocker)
  189. };
  190. #endif // QT_NO_THREAD
  191. QT_END_NAMESPACE
  192. QT_END_HEADER
  193. #endif // QREADWRITELOCK_H