118 items
NAME ↑ SIZE MODIFIED PERMS ACTIONS
.. / Parent Directory
backward — dir
2026-06-03 15:44 · rwxr-xr-x
2026-06-03 15:44 rwxr-xr-x
bits — dir
2026-06-03 15:44 · rwxr-xr-x
2026-06-03 15:44 rwxr-xr-x
debug — dir
2026-06-03 15:44 · rwxr-xr-x
2026-06-03 15:44 rwxr-xr-x
decimal — dir
2026-06-03 15:44 · rwxr-xr-x
2026-06-03 15:44 rwxr-xr-x
experimental — dir
2026-06-03 15:44 · rwxr-xr-x
2026-06-03 15:44 rwxr-xr-x
ext — dir
2026-06-03 15:44 · rwxr-xr-x
2026-06-03 15:44 rwxr-xr-x
parallel — dir
2026-06-03 15:44 · rwxr-xr-x
2026-06-03 15:44 rwxr-xr-x
pstl — dir
2026-06-03 15:44 · rwxr-xr-x
2026-06-03 15:44 rwxr-xr-x
tr1 — dir
2026-06-03 15:44 · rwxr-xr-x
2026-06-03 15:44 rwxr-xr-x
tr2 — dir
2026-06-03 15:44 · rwxr-xr-x
2026-06-03 15:44 rwxr-xr-x
2025-09-15 15:41 · rwxr-xr-x
2025-09-15 15:41 rwxr-xr-x
algorithm — 2.97 KB
2025-09-15 15:41 · rw-r--r--
2.97 KB 2025-09-15 15:41 rw-r--r--
any — 18.32 KB
2025-09-15 15:41 · rw-r--r--
18.32 KB 2025-09-15 15:41 rw-r--r--
array — 13.51 KB
2025-09-15 15:41 · rw-r--r--
13.51 KB 2025-09-15 15:41 rw-r--r--
atomic — 47.66 KB
2025-09-15 15:41 · rw-r--r--
47.66 KB 2025-09-15 15:41 rw-r--r--
barrier — 7.84 KB
2025-09-15 15:41 · rw-r--r--
7.84 KB 2025-09-15 15:41 rw-r--r--
bit — 11.9 KB
2025-09-15 15:41 · rw-r--r--
11.9 KB 2025-09-15 15:41 rw-r--r--
bitset — 44.92 KB
2025-09-15 15:41 · rw-r--r--
44.92 KB 2025-09-15 15:41 rw-r--r--
cassert — 1.61 KB
2025-09-15 15:41 · rw-r--r--
1.61 KB 2025-09-15 15:41 rw-r--r--
ccomplex — 1.3 KB
2025-09-15 15:41 · rw-r--r--
1.3 KB 2025-09-15 15:41 rw-r--r--
cctype — 2.35 KB
2025-09-15 15:41 · rw-r--r--
2.35 KB 2025-09-15 15:41 rw-r--r--
cerrno — 1.73 KB
2025-09-15 15:41 · rw-r--r--
1.73 KB 2025-09-15 15:41 rw-r--r--
cfenv — 2 KB
2025-09-15 15:41 · rw-r--r--
2 KB 2025-09-15 15:41 rw-r--r--
cfloat — 1.84 KB
2025-09-15 15:41 · rw-r--r--
1.84 KB 2025-09-15 15:41 rw-r--r--
charconv — 19.3 KB
2025-09-15 15:41 · rw-r--r--
19.3 KB 2025-09-15 15:41 rw-r--r--
chrono — 94.93 KB
2025-09-15 15:41 · rw-r--r--
94.93 KB 2025-09-15 15:41 rw-r--r--
cinttypes — 2.11 KB
2025-09-15 15:41 · rw-r--r--
2.11 KB 2025-09-15 15:41 rw-r--r--
ciso646 — 1.43 KB
2025-09-15 15:41 · rw-r--r--
1.43 KB 2025-09-15 15:41 rw-r--r--
climits — 1.87 KB
2025-09-15 15:41 · rw-r--r--
1.87 KB 2025-09-15 15:41 rw-r--r--
clocale — 1.86 KB
2025-09-15 15:41 · rw-r--r--
1.86 KB 2025-09-15 15:41 rw-r--r--
cmath — 48.22 KB
2025-09-15 15:41 · rw-r--r--
48.22 KB 2025-09-15 15:41 rw-r--r--
codecvt — 5.15 KB
2025-09-15 15:41 · rw-r--r--
5.15 KB 2025-09-15 15:41 rw-r--r--
compare — 27.61 KB
2025-09-15 15:41 · rw-r--r--
27.61 KB 2025-09-15 15:41 rw-r--r--
complex — 55.37 KB
2025-09-15 15:41 · rw-r--r--
55.37 KB 2025-09-15 15:41 rw-r--r--
complex.h — 1.56 KB
2025-09-15 15:41 · rw-r--r--
1.56 KB 2025-09-15 15:41 rw-r--r--
concepts — 11.94 KB
2025-09-15 15:41 · rw-r--r--
11.94 KB 2025-09-15 15:41 rw-r--r--
condition_variable — 12.48 KB
2025-09-15 15:41 · rw-r--r--
12.48 KB 2025-09-15 15:41 rw-r--r--
coroutine — 8.94 KB
2025-09-15 15:41 · rw-r--r--
8.94 KB 2025-09-15 15:41 rw-r--r--
csetjmp — 1.9 KB
2025-09-15 15:41 · rw-r--r--
1.9 KB 2025-09-15 15:41 rw-r--r--
csignal — 1.81 KB
2025-09-15 15:41 · rw-r--r--
1.81 KB 2025-09-15 15:41 rw-r--r--
cstdalign — 1.37 KB
2025-09-15 15:41 · rw-r--r--
1.37 KB 2025-09-15 15:41 rw-r--r--
cstdarg — 1.82 KB
2025-09-15 15:41 · rw-r--r--
1.82 KB 2025-09-15 15:41 rw-r--r--
cstdbool — 1.37 KB
2025-09-15 15:41 · rw-r--r--
1.37 KB 2025-09-15 15:41 rw-r--r--
cstddef — 6.53 KB
2025-09-15 15:41 · rw-r--r--
6.53 KB 2025-09-15 15:41 rw-r--r--
cstdint — 2.28 KB
2025-09-15 15:41 · rw-r--r--
2.28 KB 2025-09-15 15:41 rw-r--r--
cstdio — 4.33 KB
2025-09-15 15:41 · rw-r--r--
4.33 KB 2025-09-15 15:41 rw-r--r--
cstdlib — 6.18 KB
2025-09-15 15:41 · rw-r--r--
6.18 KB 2025-09-15 15:41 rw-r--r--
cstring — 3.08 KB
2025-09-15 15:41 · rw-r--r--
3.08 KB 2025-09-15 15:41 rw-r--r--
ctgmath — 1.33 KB
2025-09-15 15:41 · rw-r--r--
1.33 KB 2025-09-15 15:41 rw-r--r--
ctime — 2.24 KB
2025-09-15 15:41 · rw-r--r--
2.24 KB 2025-09-15 15:41 rw-r--r--
cuchar — 2.16 KB
2025-09-15 15:41 · rw-r--r--
2.16 KB 2025-09-15 15:41 rw-r--r--
cwchar — 6.39 KB
2025-09-15 15:41 · rw-r--r--
6.39 KB 2025-09-15 15:41 rw-r--r--
cwctype — 2.73 KB
2025-09-15 15:41 · rw-r--r--
2.73 KB 2025-09-15 15:41 rw-r--r--
cxxabi.h — 21.76 KB
2025-09-15 15:41 · rw-r--r--
21.76 KB 2025-09-15 15:41 rw-r--r--
deque — 3.88 KB
2025-09-15 15:41 · rw-r--r--
3.88 KB 2025-09-15 15:41 rw-r--r--
exception — 4.9 KB
2025-09-15 15:41 · rw-r--r--
4.9 KB 2025-09-15 15:41 rw-r--r--
execution — 1.76 KB
2025-09-15 15:41 · rw-r--r--
1.76 KB 2025-09-15 15:41 rw-r--r--
fenv.h — 1.97 KB
2025-09-15 15:41 · rw-r--r--
1.97 KB 2025-09-15 15:41 rw-r--r--
filesystem — 1.61 KB
2025-09-15 15:41 · rw-r--r--
1.61 KB 2025-09-15 15:41 rw-r--r--
forward_list — 2.63 KB
2025-09-15 15:41 · rw-r--r--
2.63 KB 2025-09-15 15:41 rw-r--r--
fstream — 39.73 KB
2025-09-15 15:41 · rw-r--r--
39.73 KB 2025-09-15 15:41 rw-r--r--
functional — 39.26 KB
2025-09-15 15:41 · rw-r--r--
39.26 KB 2025-09-15 15:41 rw-r--r--
future — 51.05 KB
2025-09-15 15:41 · rw-r--r--
51.05 KB 2025-09-15 15:41 rw-r--r--
initializer_list — 2.97 KB
2025-09-15 15:41 · rw-r--r--
2.97 KB 2025-09-15 15:41 rw-r--r--
iomanip — 16.16 KB
2025-09-15 15:41 · rw-r--r--
16.16 KB 2025-09-15 15:41 rw-r--r--
ios — 1.56 KB
2025-09-15 15:41 · rw-r--r--
1.56 KB 2025-09-15 15:41 rw-r--r--
iosfwd — 7.34 KB
2025-09-15 15:41 · rw-r--r--
7.34 KB 2025-09-15 15:41 rw-r--r--
iostream — 2.63 KB
2025-09-15 15:41 · rw-r--r--
2.63 KB 2025-09-15 15:41 rw-r--r--
istream — 33.3 KB
2025-09-15 15:41 · rw-r--r--
33.3 KB 2025-09-15 15:41 rw-r--r--
iterator — 2.69 KB
2025-09-15 15:41 · rw-r--r--
2.69 KB 2025-09-15 15:41 rw-r--r--
latch — 2.67 KB
2025-09-15 15:41 · rw-r--r--
2.67 KB 2025-09-15 15:41 rw-r--r--
limits — 69.99 KB
2025-09-15 15:41 · rw-r--r--
69.99 KB 2025-09-15 15:41 rw-r--r--
list — 3.57 KB
2025-09-15 15:41 · rw-r--r--
3.57 KB 2025-09-15 15:41 rw-r--r--
locale — 1.45 KB
2025-09-15 15:41 · rw-r--r--
1.45 KB 2025-09-15 15:41 rw-r--r--
map — 3.84 KB
2025-09-15 15:41 · rw-r--r--
3.84 KB 2025-09-15 15:41 rw-r--r--
math.h — 4.47 KB
2025-09-15 15:41 · rw-r--r--
4.47 KB 2025-09-15 15:41 rw-r--r--
memory — 4.41 KB
2025-09-15 15:41 · rw-r--r--
4.41 KB 2025-09-15 15:41 rw-r--r--
memory_resource — 20.62 KB
2025-09-15 15:41 · rw-r--r--
20.62 KB 2025-09-15 15:41 rw-r--r--
mutex — 23.66 KB
2025-09-15 15:41 · rw-r--r--
23.66 KB 2025-09-15 15:41 rw-r--r--
new — 8.15 KB
2025-09-15 15:41 · rw-r--r--
8.15 KB 2025-09-15 15:41 rw-r--r--
numbers — 6.07 KB
2025-09-15 15:41 · rw-r--r--
6.07 KB 2025-09-15 15:41 rw-r--r--
numeric — 25.5 KB
2025-09-15 15:41 · rw-r--r--
25.5 KB 2025-09-15 15:41 rw-r--r--
optional — 39.23 KB
2025-09-15 15:41 · rw-r--r--
39.23 KB 2025-09-15 15:41 rw-r--r--
ostream — 25.37 KB
2025-09-15 15:41 · rw-r--r--
25.37 KB 2025-09-15 15:41 rw-r--r--
queue — 2.41 KB
2025-09-15 15:41 · rw-r--r--
2.41 KB 2025-09-15 15:41 rw-r--r--
random — 1.65 KB
2025-09-15 15:41 · rw-r--r--
1.65 KB 2025-09-15 15:41 rw-r--r--
ranges — 104.69 KB
2025-09-15 15:41 · rw-r--r--
104.69 KB 2025-09-15 15:41 rw-r--r--
ratio — 19.64 KB
2025-09-15 15:41 · rw-r--r--
19.64 KB 2025-09-15 15:41 rw-r--r--
regex — 2.79 KB
2025-09-15 15:41 · rw-r--r--
2.79 KB 2025-09-15 15:41 rw-r--r--
scoped_allocator — 17.24 KB
2025-09-15 15:41 · rw-r--r--
17.24 KB 2025-09-15 15:41 rw-r--r--
semaphore — 2.93 KB
2025-09-15 15:41 · rw-r--r--
2.93 KB 2025-09-15 15:41 rw-r--r--
set — 3.71 KB
2025-09-15 15:41 · rw-r--r--
3.71 KB 2025-09-15 15:41 rw-r--r--
shared_mutex — 24.01 KB
2025-09-15 15:41 · rw-r--r--
24.01 KB 2025-09-15 15:41 rw-r--r--
source_location — 2.68 KB
2025-09-15 15:41 · rw-r--r--
2.68 KB 2025-09-15 15:41 rw-r--r--
span — 12.82 KB
2025-09-15 15:41 · rw-r--r--
12.82 KB 2025-09-15 15:41 rw-r--r--
sstream — 38.31 KB
2025-09-15 15:41 · rw-r--r--
38.31 KB 2025-09-15 15:41 rw-r--r--
stack — 2.33 KB
2025-09-15 15:41 · rw-r--r--
2.33 KB 2025-09-15 15:41 rw-r--r--
stdexcept — 9.65 KB
2025-09-15 15:41 · rw-r--r--
9.65 KB 2025-09-15 15:41 rw-r--r--
stdlib.h — 2.2 KB
2025-09-15 15:41 · rw-r--r--
2.2 KB 2025-09-15 15:41 rw-r--r--
stop_token — 15.61 KB
2025-09-15 15:41 · rw-r--r--
15.61 KB 2025-09-15 15:41 rw-r--r--
streambuf — 29.19 KB
2025-09-15 15:41 · rw-r--r--
29.19 KB 2025-09-15 15:41 rw-r--r--
string — 4.54 KB
2025-09-15 15:41 · rw-r--r--
4.54 KB 2025-09-15 15:41 rw-r--r--
string_view — 25.59 KB
2025-09-15 15:41 · rw-r--r--
25.59 KB 2025-09-15 15:41 rw-r--r--
syncstream — 8.13 KB
2025-09-15 15:41 · rw-r--r--
8.13 KB 2025-09-15 15:41 rw-r--r--
system_error — 14.65 KB
2025-09-15 15:41 · rw-r--r--
14.65 KB 2025-09-15 15:41 rw-r--r--
tgmath.h — 1.33 KB
2025-09-15 15:41 · rw-r--r--
1.33 KB 2025-09-15 15:41 rw-r--r--
thread — 5.78 KB
2025-09-15 15:41 · rw-r--r--
5.78 KB 2025-09-15 15:41 rw-r--r--
tuple — 61.71 KB
2025-09-15 15:41 · rw-r--r--
61.71 KB 2025-09-15 15:41 rw-r--r--
type_traits — 105.12 KB
2025-09-15 15:41 · rw-r--r--
105.12 KB 2025-09-15 15:41 rw-r--r--
typeindex — 3.43 KB
2025-09-15 15:41 · rw-r--r--
3.43 KB 2025-09-15 15:41 rw-r--r--
typeinfo — 7.56 KB
2025-09-15 15:41 · rw-r--r--
7.56 KB 2025-09-15 15:41 rw-r--r--
unordered_map — 3.39 KB
2025-09-15 15:41 · rw-r--r--
3.39 KB 2025-09-15 15:41 rw-r--r--
unordered_set — 3.26 KB
2025-09-15 15:41 · rw-r--r--
3.26 KB 2025-09-15 15:41 rw-r--r--
utility — 14.48 KB
2025-09-15 15:41 · rw-r--r--
14.48 KB 2025-09-15 15:41 rw-r--r--
valarray — 39.74 KB
2025-09-15 15:41 · rw-r--r--
39.74 KB 2025-09-15 15:41 rw-r--r--
variant — 61.39 KB
2025-09-15 15:41 · rw-r--r--
61.39 KB 2025-09-15 15:41 rw-r--r--
vector — 4.17 KB
2025-09-15 15:41 · rw-r--r--
4.17 KB 2025-09-15 15:41 rw-r--r--
version — 9.05 KB
2025-09-15 15:41 · rw-r--r--
9.05 KB 2025-09-15 15:41 rw-r--r--
ONLINE
11
118 items
02:11:17
TERMINAL FM
Edit
Preview
Download
Rename
Copy
Chmod
Delete
// -*- C++ -*- // Copyright (C) 2008-2021 Free Software Foundation, Inc. // // This file is part of the GNU ISO C++ Library. This library is free // software; you can redistribute it and/or modify it under the // terms of the GNU General Public License as published by the // Free Software Foundation; either version 3, or (at your option) // any later version. // This library is distributed in the hope that it will be useful, // but WITHOUT ANY WARRANTY; without even the implied warranty of // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the // GNU General Public License for more details. // Under Section 7 of GPL version 3, you are granted additional // permissions described in the GCC Runtime Library Exception, version // 3.1, as published by the Free Software Foundation. // You should have received a copy of the GNU General Public License and // a copy of the GCC Runtime Library Exception along with this program; // see the files COPYING3 and COPYING.RUNTIME respectively. If not, see // . /** @file include/condition_variable * This is a Standard C++ Library header. */ #ifndef _GLIBCXX_CONDITION_VARIABLE #define _GLIBCXX_CONDITION_VARIABLE 1 #pragma GCC system_header #if __cplusplus < 201103L # include #else #include #include #include #include #include #include #if __cplusplus > 201703L # include #endif #if defined(_GLIBCXX_HAS_GTHREADS) namespace std _GLIBCXX_VISIBILITY(default) { _GLIBCXX_BEGIN_NAMESPACE_VERSION /** * @defgroup condition_variables Condition Variables * @ingroup concurrency * * Classes for condition_variable support. * @{ */ /// cv_status enum class cv_status { no_timeout, timeout }; /// condition_variable class condition_variable { using steady_clock = chrono::steady_clock; using system_clock = chrono::system_clock; #ifdef _GLIBCXX_USE_PTHREAD_COND_CLOCKWAIT using __clock_t = steady_clock; #else using __clock_t = system_clock; #endif __condvar _M_cond; public: typedef __gthread_cond_t* native_handle_type; condition_variable() noexcept; ~condition_variable() noexcept; condition_variable(const condition_variable&) = delete; condition_variable& operator=(const condition_variable&) = delete; void notify_one() noexcept; void notify_all() noexcept; void wait(unique_lock& __lock) noexcept; template void wait(unique_lock& __lock, _Predicate __p) { while (!__p()) wait(__lock); } #ifdef _GLIBCXX_USE_PTHREAD_COND_CLOCKWAIT template cv_status wait_until(unique_lock& __lock, const chrono::time_point& __atime) { return __wait_until_impl(__lock, __atime); } #endif template cv_status wait_until(unique_lock& __lock, const chrono::time_point& __atime) { return __wait_until_impl(__lock, __atime); } template cv_status wait_until(unique_lock& __lock, const chrono::time_point<_Clock, _Duration>& __atime) { #if __cplusplus > 201703L static_assert(chrono::is_clock_v<_Clock>); #endif using __s_dur = typename __clock_t::duration; const typename _Clock::time_point __c_entry = _Clock::now(); const __clock_t::time_point __s_entry = __clock_t::now(); const auto __delta = __atime - __c_entry; const auto __s_atime = __s_entry + chrono::__detail::ceil<__s_dur>(__delta); if (__wait_until_impl(__lock, __s_atime) == cv_status::no_timeout) return cv_status::no_timeout; // We got a timeout when measured against __clock_t but // we need to check against the caller-supplied clock // to tell whether we should return a timeout. if (_Clock::now() < __atime) return cv_status::no_timeout; return cv_status::timeout; } template bool wait_until(unique_lock& __lock, const chrono::time_point<_Clock, _Duration>& __atime, _Predicate __p) { while (!__p()) if (wait_until(__lock, __atime) == cv_status::timeout) return __p(); return true; } template cv_status wait_for(unique_lock& __lock, const chrono::duration<_Rep, _Period>& __rtime) { using __dur = typename steady_clock::duration; return wait_until(__lock, steady_clock::now() + chrono::__detail::ceil<__dur>(__rtime)); } template bool wait_for(unique_lock& __lock, const chrono::duration<_Rep, _Period>& __rtime, _Predicate __p) { using __dur = typename steady_clock::duration; return wait_until(__lock, steady_clock::now() + chrono::__detail::ceil<__dur>(__rtime), std::move(__p)); } native_handle_type native_handle() { return _M_cond.native_handle(); } private: #ifdef _GLIBCXX_USE_PTHREAD_COND_CLOCKWAIT template cv_status __wait_until_impl(unique_lock& __lock, const chrono::time_point& __atime) { auto __s = chrono::time_point_cast(__atime); auto __ns = chrono::duration_cast(__atime - __s); __gthread_time_t __ts = { static_cast(__s.time_since_epoch().count()), static_cast(__ns.count()) }; _M_cond.wait_until(*__lock.mutex(), CLOCK_MONOTONIC, __ts); return (steady_clock::now() < __atime ? cv_status::no_timeout : cv_status::timeout); } #endif template cv_status __wait_until_impl(unique_lock& __lock, const chrono::time_point& __atime) { auto __s = chrono::time_point_cast(__atime); auto __ns = chrono::duration_cast(__atime - __s); __gthread_time_t __ts = { static_cast(__s.time_since_epoch().count()), static_cast(__ns.count()) }; _M_cond.wait_until(*__lock.mutex(), __ts); return (system_clock::now() < __atime ? cv_status::no_timeout : cv_status::timeout); } }; void notify_all_at_thread_exit(condition_variable&, unique_lock); struct __at_thread_exit_elt { __at_thread_exit_elt* _M_next; void (*_M_cb)(void*); }; inline namespace _V2 { /// condition_variable_any // Like above, but mutex is not required to have try_lock. class condition_variable_any { #ifdef _GLIBCXX_USE_PTHREAD_COND_CLOCKWAIT using __clock_t = chrono::steady_clock; #else using __clock_t = chrono::system_clock; #endif condition_variable _M_cond; shared_ptr _M_mutex; // scoped unlock - unlocks in ctor, re-locks in dtor template struct _Unlock { explicit _Unlock(_Lock& __lk) : _M_lock(__lk) { __lk.unlock(); } #pragma GCC diagnostic push #pragma GCC diagnostic ignored "-Wdeprecated-declarations" ~_Unlock() noexcept(false) { if (uncaught_exception()) { __try { _M_lock.lock(); } __catch(const __cxxabiv1::__forced_unwind&) { __throw_exception_again; } __catch(...) { } } else _M_lock.lock(); } #pragma GCC diagnostic pop _Unlock(const _Unlock&) = delete; _Unlock& operator=(const _Unlock&) = delete; _Lock& _M_lock; }; public: condition_variable_any() : _M_mutex(std::make_shared()) { } ~condition_variable_any() = default; condition_variable_any(const condition_variable_any&) = delete; condition_variable_any& operator=(const condition_variable_any&) = delete; void notify_one() noexcept { lock_guard __lock(*_M_mutex); _M_cond.notify_one(); } void notify_all() noexcept { lock_guard __lock(*_M_mutex); _M_cond.notify_all(); } template void wait(_Lock& __lock) { shared_ptr __mutex = _M_mutex; unique_lock __my_lock(*__mutex); _Unlock<_Lock> __unlock(__lock); // *__mutex must be unlocked before re-locking __lock so move // ownership of *__mutex lock to an object with shorter lifetime. unique_lock __my_lock2(std::move(__my_lock)); _M_cond.wait(__my_lock2); } template void wait(_Lock& __lock, _Predicate __p) { while (!__p()) wait(__lock); } template cv_status wait_until(_Lock& __lock, const chrono::time_point<_Clock, _Duration>& __atime) { shared_ptr __mutex = _M_mutex; unique_lock __my_lock(*__mutex); _Unlock<_Lock> __unlock(__lock); // *__mutex must be unlocked before re-locking __lock so move // ownership of *__mutex lock to an object with shorter lifetime. unique_lock __my_lock2(std::move(__my_lock)); return _M_cond.wait_until(__my_lock2, __atime); } template bool wait_until(_Lock& __lock, const chrono::time_point<_Clock, _Duration>& __atime, _Predicate __p) { while (!__p()) if (wait_until(__lock, __atime) == cv_status::timeout) return __p(); return true; } template cv_status wait_for(_Lock& __lock, const chrono::duration<_Rep, _Period>& __rtime) { return wait_until(__lock, __clock_t::now() + __rtime); } template bool wait_for(_Lock& __lock, const chrono::duration<_Rep, _Period>& __rtime, _Predicate __p) { return wait_until(__lock, __clock_t::now() + __rtime, std::move(__p)); } #ifdef __cpp_lib_jthread template bool wait(_Lock& __lock, stop_token __stoken, _Predicate __p) { if (__stoken.stop_requested()) { return __p(); } std::stop_callback __cb(__stoken, [this] { notify_all(); }); shared_ptr __mutex = _M_mutex; while (!__p()) { unique_lock __my_lock(*__mutex); if (__stoken.stop_requested()) { return false; } // *__mutex must be unlocked before re-locking __lock so move // ownership of *__mutex lock to an object with shorter lifetime. _Unlock<_Lock> __unlock(__lock); unique_lock __my_lock2(std::move(__my_lock)); _M_cond.wait(__my_lock2); } return true; } template bool wait_until(_Lock& __lock, stop_token __stoken, const chrono::time_point<_Clock, _Duration>& __abs_time, _Predicate __p) { if (__stoken.stop_requested()) { return __p(); } std::stop_callback __cb(__stoken, [this] { notify_all(); }); shared_ptr __mutex = _M_mutex; while (!__p()) { bool __stop; { unique_lock __my_lock(*__mutex); if (__stoken.stop_requested()) { return false; } _Unlock<_Lock> __u(__lock); unique_lock __my_lock2(std::move(__my_lock)); const auto __status = _M_cond.wait_until(__my_lock2, __abs_time); __stop = (__status == std::cv_status::timeout) || __stoken.stop_requested(); } if (__stop) { return __p(); } } return true; } template bool wait_for(_Lock& __lock, stop_token __stoken, const chrono::duration<_Rep, _Period>& __rel_time, _Predicate __p) { auto __abst = std::chrono::steady_clock::now() + __rel_time; return wait_until(__lock, std::move(__stoken), __abst, std::move(__p)); } #endif }; } // end inline namespace /// @} group condition_variables _GLIBCXX_END_NAMESPACE_VERSION } // namespace #endif // _GLIBCXX_HAS_GTHREADS #endif // C++11 #endif // _GLIBCXX_CONDITION_VARIABLE