192 lines · c
1// -*- C++ -*-2//===----------------------------------------------------------------------===//3//4// Part of the LLVM Project, under the Apache License v2.0 with LLVM Exceptions.5// See https://llvm.org/LICENSE.txt for license information.6// SPDX-License-Identifier: Apache-2.0 WITH LLVM-exception7//8//===----------------------------------------------------------------------===//9 10#ifndef _LIBCPP___THREAD_SUPPORT_C11_H11#define _LIBCPP___THREAD_SUPPORT_C11_H12 13#include <__chrono/convert_to_timespec.h>14#include <__chrono/duration.h>15#include <__config>16#include <ctime>17#include <errno.h>18#include <threads.h>19 20#ifndef _LIBCPP_HAS_NO_PRAGMA_SYSTEM_HEADER21# pragma GCC system_header22#endif23 24_LIBCPP_BEGIN_NAMESPACE_STD25 26using __libcpp_timespec_t = ::timespec;27 28//29// Mutex30//31typedef mtx_t __libcpp_mutex_t;32// mtx_t is a struct so using {} for initialization is valid.33#define _LIBCPP_MUTEX_INITIALIZER \34 {}35 36typedef mtx_t __libcpp_recursive_mutex_t;37 38inline _LIBCPP_HIDE_FROM_ABI int __libcpp_recursive_mutex_init(__libcpp_recursive_mutex_t* __m) {39 return mtx_init(__m, mtx_plain | mtx_recursive) == thrd_success ? 0 : EINVAL;40}41 42inline _LIBCPP_HIDE_FROM_ABI _LIBCPP_NO_THREAD_SAFETY_ANALYSIS int43__libcpp_recursive_mutex_lock(__libcpp_recursive_mutex_t* __m) {44 return mtx_lock(__m) == thrd_success ? 0 : EINVAL;45}46 47inline _LIBCPP_HIDE_FROM_ABI _LIBCPP_NO_THREAD_SAFETY_ANALYSIS bool48__libcpp_recursive_mutex_trylock(__libcpp_recursive_mutex_t* __m) {49 return mtx_trylock(__m) == thrd_success;50}51 52inline _LIBCPP_HIDE_FROM_ABI _LIBCPP_NO_THREAD_SAFETY_ANALYSIS int53__libcpp_recursive_mutex_unlock(__libcpp_recursive_mutex_t* __m) {54 return mtx_unlock(__m) == thrd_success ? 0 : EINVAL;55}56 57inline _LIBCPP_HIDE_FROM_ABI int __libcpp_recursive_mutex_destroy(__libcpp_recursive_mutex_t* __m) {58 mtx_destroy(__m);59 return 0;60}61 62inline _LIBCPP_HIDE_FROM_ABI _LIBCPP_NO_THREAD_SAFETY_ANALYSIS int __libcpp_mutex_lock(__libcpp_mutex_t* __m) {63 return mtx_lock(__m) == thrd_success ? 0 : EINVAL;64}65 66inline _LIBCPP_HIDE_FROM_ABI _LIBCPP_NO_THREAD_SAFETY_ANALYSIS bool __libcpp_mutex_trylock(__libcpp_mutex_t* __m) {67 return mtx_trylock(__m) == thrd_success;68}69 70inline _LIBCPP_HIDE_FROM_ABI _LIBCPP_NO_THREAD_SAFETY_ANALYSIS int __libcpp_mutex_unlock(__libcpp_mutex_t* __m) {71 return mtx_unlock(__m) == thrd_success ? 0 : EINVAL;72}73 74inline _LIBCPP_HIDE_FROM_ABI int __libcpp_mutex_destroy(__libcpp_mutex_t* __m) {75 mtx_destroy(__m);76 return 0;77}78 79//80// Condition Variable81//82typedef cnd_t __libcpp_condvar_t;83// cnd_t is a struct so using {} for initialization is valid.84#define _LIBCPP_CONDVAR_INITIALIZER \85 {}86 87inline _LIBCPP_HIDE_FROM_ABI int __libcpp_condvar_signal(__libcpp_condvar_t* __cv) {88 return cnd_signal(__cv) == thrd_success ? 0 : EINVAL;89}90 91inline _LIBCPP_HIDE_FROM_ABI int __libcpp_condvar_broadcast(__libcpp_condvar_t* __cv) {92 return cnd_broadcast(__cv) == thrd_success ? 0 : EINVAL;93}94 95inline _LIBCPP_HIDE_FROM_ABI _LIBCPP_NO_THREAD_SAFETY_ANALYSIS int96__libcpp_condvar_wait(__libcpp_condvar_t* __cv, __libcpp_mutex_t* __m) {97 return cnd_wait(__cv, __m) == thrd_success ? 0 : EINVAL;98}99 100inline _LIBCPP_HIDE_FROM_ABI _LIBCPP_NO_THREAD_SAFETY_ANALYSIS int101__libcpp_condvar_timedwait(__libcpp_condvar_t* __cv, __libcpp_mutex_t* __m, timespec* __ts) {102 int __ec = cnd_timedwait(__cv, __m, __ts);103 return __ec == thrd_timedout ? ETIMEDOUT : __ec;104}105 106inline _LIBCPP_HIDE_FROM_ABI int __libcpp_condvar_destroy(__libcpp_condvar_t* __cv) {107 cnd_destroy(__cv);108 return 0;109}110 111//112// Execute once113//114typedef ::once_flag __libcpp_exec_once_flag;115#define _LIBCPP_EXEC_ONCE_INITIALIZER ONCE_FLAG_INIT116 117inline _LIBCPP_HIDE_FROM_ABI int __libcpp_execute_once(__libcpp_exec_once_flag* flag, void (*init_routine)(void)) {118 ::call_once(flag, init_routine);119 return 0;120}121 122//123// Thread id124//125typedef thrd_t __libcpp_thread_id;126 127// Returns non-zero if the thread ids are equal, otherwise 0128inline _LIBCPP_HIDE_FROM_ABI bool __libcpp_thread_id_equal(__libcpp_thread_id t1, __libcpp_thread_id t2) {129 return thrd_equal(t1, t2) != 0;130}131 132// Returns non-zero if t1 < t2, otherwise 0133inline _LIBCPP_HIDE_FROM_ABI bool __libcpp_thread_id_less(__libcpp_thread_id t1, __libcpp_thread_id t2) {134 return t1 < t2;135}136 137//138// Thread139//140#define _LIBCPP_NULL_THREAD 0U141 142typedef thrd_t __libcpp_thread_t;143 144inline _LIBCPP_HIDE_FROM_ABI __libcpp_thread_id __libcpp_thread_get_id(const __libcpp_thread_t* __t) { return *__t; }145 146inline _LIBCPP_HIDE_FROM_ABI bool __libcpp_thread_isnull(const __libcpp_thread_t* __t) {147 return __libcpp_thread_get_id(__t) == 0;148}149 150inline _LIBCPP_HIDE_FROM_ABI int __libcpp_thread_create(__libcpp_thread_t* __t, void* (*__func)(void*), void* __arg) {151 int __ec = thrd_create(__t, reinterpret_cast<thrd_start_t>(__func), __arg);152 return __ec == thrd_nomem ? ENOMEM : __ec;153}154 155inline _LIBCPP_HIDE_FROM_ABI __libcpp_thread_id __libcpp_thread_get_current_id() { return thrd_current(); }156 157inline _LIBCPP_HIDE_FROM_ABI int __libcpp_thread_join(__libcpp_thread_t* __t) {158 return thrd_join(*__t, nullptr) == thrd_success ? 0 : EINVAL;159}160 161inline _LIBCPP_HIDE_FROM_ABI int __libcpp_thread_detach(__libcpp_thread_t* __t) {162 return thrd_detach(*__t) == thrd_success ? 0 : EINVAL;163}164 165inline _LIBCPP_HIDE_FROM_ABI void __libcpp_thread_yield() { thrd_yield(); }166 167inline _LIBCPP_HIDE_FROM_ABI void __libcpp_thread_sleep_for(const chrono::nanoseconds& __ns) {168 __libcpp_timespec_t __ts = std::__convert_to_timespec<__libcpp_timespec_t>(__ns);169 thrd_sleep(&__ts, nullptr);170}171 172//173// Thread local storage174//175#define _LIBCPP_TLS_DESTRUCTOR_CC /* nothing */176 177typedef tss_t __libcpp_tls_key;178 179inline _LIBCPP_HIDE_FROM_ABI int __libcpp_tls_create(__libcpp_tls_key* __key, void (*__at_exit)(void*)) {180 return tss_create(__key, __at_exit) == thrd_success ? 0 : EINVAL;181}182 183inline _LIBCPP_HIDE_FROM_ABI void* __libcpp_tls_get(__libcpp_tls_key __key) { return tss_get(__key); }184 185inline _LIBCPP_HIDE_FROM_ABI int __libcpp_tls_set(__libcpp_tls_key __key, void* __p) {186 return tss_set(__key, __p) == thrd_success ? 0 : EINVAL;187}188 189_LIBCPP_END_NAMESPACE_STD190 191#endif // _LIBCPP___THREAD_SUPPORT_C11_H192