1 // condition_variable -*- C++ -*-
3 // Copyright (C) 2008-2023 Free Software Foundation, Inc.
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)
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.
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.
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/>.
25 #include <condition_variable>
28 #ifdef _GLIBCXX_HAS_GTHREADS
30 namespace std
_GLIBCXX_VISIBILITY(default)
32 _GLIBCXX_BEGIN_NAMESPACE_VERSION
34 condition_variable::condition_variable() noexcept
= default;
36 condition_variable::~condition_variable() noexcept
= default;
39 condition_variable::wait(unique_lock
<mutex
>& __lock
)
41 _M_cond
.wait(*__lock
.mutex());
45 condition_variable::notify_one() noexcept
51 condition_variable::notify_all() noexcept
57 __at_thread_exit(__at_thread_exit_elt
*);
65 auto elt
= (__at_thread_exit_elt
*)p
;
68 auto next
= elt
->_M_next
;
76 auto elt
= (__at_thread_exit_elt
*)__gthread_getspecific(key
);
77 __gthread_setspecific(key
, nullptr);
81 struct notifier final
: __at_thread_exit_elt
83 notifier(condition_variable
& cv
, unique_lock
<mutex
>& l
)
84 : cv(&cv
), mx(l
.release())
86 _M_cb
= ¬ifier::run
;
87 __at_thread_exit(this);
96 condition_variable
* cv
;
99 static void run(void* p
) { delete static_cast<notifier
*>(p
); }
105 key_s() { __gthread_key_create (&key
, run
); }
106 ~key_s() { __gthread_key_delete (key
); }
109 // Also make sure the callbacks are run by std::exit.
115 __at_thread_exit(__at_thread_exit_elt
* elt
)
117 static __gthread_once_t once
= __GTHREAD_ONCE_INIT
;
118 __gthread_once (&once
, key_init
);
120 elt
->_M_next
= (__at_thread_exit_elt
*)__gthread_getspecific(key
);
121 __gthread_setspecific(key
, elt
);
125 notify_all_at_thread_exit(condition_variable
& cv
, unique_lock
<mutex
> l
)
127 (void) new notifier
{cv
, l
};
130 _GLIBCXX_END_NAMESPACE_VERSION
133 #endif // _GLIBCXX_HAS_GTHREADS