| 1 | // std::mutex implementation -*- C++ -*- | 
|---|
| 2 |  | 
|---|
| 3 | // Copyright (C) 2003-2019 Free Software Foundation, Inc. | 
|---|
| 4 | // | 
|---|
| 5 | // This file is part of the GNU ISO C++ Library.  This library is free | 
|---|
| 6 | // software; you can redistribute it and/or modify it under the | 
|---|
| 7 | // terms of the GNU General Public License as published by the | 
|---|
| 8 | // Free Software Foundation; either version 3, or (at your option) | 
|---|
| 9 | // any later version. | 
|---|
| 10 |  | 
|---|
| 11 | // This library is distributed in the hope that it will be useful, | 
|---|
| 12 | // but WITHOUT ANY WARRANTY; without even the implied warranty of | 
|---|
| 13 | // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the | 
|---|
| 14 | // GNU General Public License for more details. | 
|---|
| 15 |  | 
|---|
| 16 | // Under Section 7 of GPL version 3, you are granted additional | 
|---|
| 17 | // permissions described in the GCC Runtime Library Exception, version | 
|---|
| 18 | // 3.1, as published by the Free Software Foundation. | 
|---|
| 19 |  | 
|---|
| 20 | // You should have received a copy of the GNU General Public License and | 
|---|
| 21 | // a copy of the GCC Runtime Library Exception along with this program; | 
|---|
| 22 | // see the files COPYING3 and COPYING.RUNTIME respectively.  If not, see | 
|---|
| 23 | // <http://www.gnu.org/licenses/>. | 
|---|
| 24 |  | 
|---|
| 25 | /** @file bits/std_mutex.h | 
|---|
| 26 | *  This is an internal header file, included by other library headers. | 
|---|
| 27 | *  Do not attempt to use it directly. @headername{mutex} | 
|---|
| 28 | */ | 
|---|
| 29 |  | 
|---|
| 30 | #ifndef _GLIBCXX_MUTEX_H | 
|---|
| 31 | #define _GLIBCXX_MUTEX_H 1 | 
|---|
| 32 |  | 
|---|
| 33 | #pragma GCC system_header | 
|---|
| 34 |  | 
|---|
| 35 | #if __cplusplus < 201103L | 
|---|
| 36 | # include <bits/c++0x_warning.h> | 
|---|
| 37 | #else | 
|---|
| 38 |  | 
|---|
| 39 | #include <system_error> | 
|---|
| 40 | #include <bits/functexcept.h> | 
|---|
| 41 | #include <bits/gthr.h> | 
|---|
| 42 |  | 
|---|
| 43 | namespace std _GLIBCXX_VISIBILITY(default) | 
|---|
| 44 | { | 
|---|
| 45 | _GLIBCXX_BEGIN_NAMESPACE_VERSION | 
|---|
| 46 |  | 
|---|
| 47 | /** | 
|---|
| 48 | * @defgroup mutexes Mutexes | 
|---|
| 49 | * @ingroup concurrency | 
|---|
| 50 | * | 
|---|
| 51 | * Classes for mutex support. | 
|---|
| 52 | * @{ | 
|---|
| 53 | */ | 
|---|
| 54 |  | 
|---|
| 55 | #ifdef _GLIBCXX_HAS_GTHREADS | 
|---|
| 56 | // Common base class for std::mutex and std::timed_mutex | 
|---|
| 57 | class __mutex_base | 
|---|
| 58 | { | 
|---|
| 59 | protected: | 
|---|
| 60 | typedef __gthread_mutex_t			__native_type; | 
|---|
| 61 |  | 
|---|
| 62 | #ifdef __GTHREAD_MUTEX_INIT | 
|---|
| 63 | __native_type  _M_mutex = __GTHREAD_MUTEX_INIT; | 
|---|
| 64 |  | 
|---|
| 65 | constexpr __mutex_base() noexcept = default; | 
|---|
| 66 | #else | 
|---|
| 67 | __native_type  _M_mutex; | 
|---|
| 68 |  | 
|---|
| 69 | __mutex_base() noexcept | 
|---|
| 70 | { | 
|---|
| 71 | // XXX EAGAIN, ENOMEM, EPERM, EBUSY(may), EINVAL(may) | 
|---|
| 72 | __GTHREAD_MUTEX_INIT_FUNCTION(&_M_mutex); | 
|---|
| 73 | } | 
|---|
| 74 |  | 
|---|
| 75 | ~__mutex_base() noexcept { __gthread_mutex_destroy(&_M_mutex); } | 
|---|
| 76 | #endif | 
|---|
| 77 |  | 
|---|
| 78 | __mutex_base(const __mutex_base&) = delete; | 
|---|
| 79 | __mutex_base& operator=(const __mutex_base&) = delete; | 
|---|
| 80 | }; | 
|---|
| 81 |  | 
|---|
| 82 | /// The standard mutex type. | 
|---|
| 83 | class mutex : private __mutex_base | 
|---|
| 84 | { | 
|---|
| 85 | public: | 
|---|
| 86 | typedef __native_type* 			native_handle_type; | 
|---|
| 87 |  | 
|---|
| 88 | #ifdef __GTHREAD_MUTEX_INIT | 
|---|
| 89 | constexpr | 
|---|
| 90 | #endif | 
|---|
| 91 | mutex() noexcept = default; | 
|---|
| 92 | ~mutex() = default; | 
|---|
| 93 |  | 
|---|
| 94 | mutex(const mutex&) = delete; | 
|---|
| 95 | mutex& operator=(const mutex&) = delete; | 
|---|
| 96 |  | 
|---|
| 97 | void | 
|---|
| 98 | lock() | 
|---|
| 99 | { | 
|---|
| 100 | int __e = __gthread_mutex_lock(&_M_mutex); | 
|---|
| 101 |  | 
|---|
| 102 | // EINVAL, EAGAIN, EBUSY, EINVAL, EDEADLK(may) | 
|---|
| 103 | if (__e) | 
|---|
| 104 | __throw_system_error(__e); | 
|---|
| 105 | } | 
|---|
| 106 |  | 
|---|
| 107 | bool | 
|---|
| 108 | try_lock() noexcept | 
|---|
| 109 | { | 
|---|
| 110 | // XXX EINVAL, EAGAIN, EBUSY | 
|---|
| 111 | return !__gthread_mutex_trylock(&_M_mutex); | 
|---|
| 112 | } | 
|---|
| 113 |  | 
|---|
| 114 | void | 
|---|
| 115 | unlock() | 
|---|
| 116 | { | 
|---|
| 117 | // XXX EINVAL, EAGAIN, EPERM | 
|---|
| 118 | __gthread_mutex_unlock(&_M_mutex); | 
|---|
| 119 | } | 
|---|
| 120 |  | 
|---|
| 121 | native_handle_type | 
|---|
| 122 | native_handle() noexcept | 
|---|
| 123 | { return &_M_mutex; } | 
|---|
| 124 | }; | 
|---|
| 125 |  | 
|---|
| 126 | #endif // _GLIBCXX_HAS_GTHREADS | 
|---|
| 127 |  | 
|---|
| 128 | /// Do not acquire ownership of the mutex. | 
|---|
| 129 | struct defer_lock_t { explicit defer_lock_t() = default; }; | 
|---|
| 130 |  | 
|---|
| 131 | /// Try to acquire ownership of the mutex without blocking. | 
|---|
| 132 | struct try_to_lock_t { explicit try_to_lock_t() = default; }; | 
|---|
| 133 |  | 
|---|
| 134 | /// Assume the calling thread has already obtained mutex ownership | 
|---|
| 135 | /// and manage it. | 
|---|
| 136 | struct adopt_lock_t { explicit adopt_lock_t() = default; }; | 
|---|
| 137 |  | 
|---|
| 138 | /// Tag used to prevent a scoped lock from acquiring ownership of a mutex. | 
|---|
| 139 | _GLIBCXX17_INLINE constexpr defer_lock_t	defer_lock { }; | 
|---|
| 140 |  | 
|---|
| 141 | /// Tag used to prevent a scoped lock from blocking if a mutex is locked. | 
|---|
| 142 | _GLIBCXX17_INLINE constexpr try_to_lock_t	try_to_lock { }; | 
|---|
| 143 |  | 
|---|
| 144 | /// Tag used to make a scoped lock take ownership of a locked mutex. | 
|---|
| 145 | _GLIBCXX17_INLINE constexpr adopt_lock_t	adopt_lock { }; | 
|---|
| 146 |  | 
|---|
| 147 | /** @brief A simple scoped lock type. | 
|---|
| 148 | * | 
|---|
| 149 | * A lock_guard controls mutex ownership within a scope, releasing | 
|---|
| 150 | * ownership in the destructor. | 
|---|
| 151 | */ | 
|---|
| 152 | template<typename _Mutex> | 
|---|
| 153 | class lock_guard | 
|---|
| 154 | { | 
|---|
| 155 | public: | 
|---|
| 156 | typedef _Mutex mutex_type; | 
|---|
| 157 |  | 
|---|
| 158 | explicit lock_guard(mutex_type& __m) : _M_device(__m) | 
|---|
| 159 | { _M_device.lock(); } | 
|---|
| 160 |  | 
|---|
| 161 | lock_guard(mutex_type& __m, adopt_lock_t) noexcept : _M_device(__m) | 
|---|
| 162 | { } // calling thread owns mutex | 
|---|
| 163 |  | 
|---|
| 164 | ~lock_guard() | 
|---|
| 165 | { _M_device.unlock(); } | 
|---|
| 166 |  | 
|---|
| 167 | lock_guard(const lock_guard&) = delete; | 
|---|
| 168 | lock_guard& operator=(const lock_guard&) = delete; | 
|---|
| 169 |  | 
|---|
| 170 | private: | 
|---|
| 171 | mutex_type&  _M_device; | 
|---|
| 172 | }; | 
|---|
| 173 |  | 
|---|
| 174 | // @} group mutexes | 
|---|
| 175 | _GLIBCXX_END_NAMESPACE_VERSION | 
|---|
| 176 | } // namespace | 
|---|
| 177 | #endif // C++11 | 
|---|
| 178 | #endif // _GLIBCXX_MUTEX_H | 
|---|
| 179 |  | 
|---|