|
@@ -19,20 +19,83 @@
|
|
|
|
|
|
#ifndef _LIBCPP_HAS_NO_THREADS
|
|
|
|
|
|
-#if defined(_LIBCPP_HAS_THREAD_API_PTHREAD)
|
|
|
+#if defined(_LIBCPP_HAS_THREAD_API_EXTERNAL) && (!defined(__has_include) || __has_include(<__external_threading>))
|
|
|
+#include <__external_threading>
|
|
|
+#else
|
|
|
#include <pthread.h>
|
|
|
#include <sched.h>
|
|
|
#endif
|
|
|
|
|
|
-_LIBCPP_BEGIN_NAMESPACE_STD
|
|
|
+#if defined(_LIBCPP_HAS_THREAD_API_EXTERNAL)
|
|
|
+#define _LIBCPP_THREAD_ABI_VISIBILITY _LIBCPP_FUNC_VIS
|
|
|
+#else
|
|
|
+#define _LIBCPP_THREAD_ABI_VISIBILITY inline _LIBCPP_INLINE_VISIBILITY
|
|
|
+#endif
|
|
|
|
|
|
-#if defined(_LIBCPP_HAS_THREAD_API_PTHREAD)
|
|
|
+_LIBCPP_BEGIN_NAMESPACE_STD
|
|
|
|
|
|
// Mutex
|
|
|
-#define _LIBCPP_MUTEX_INITIALIZER PTHREAD_MUTEX_INITIALIZER
|
|
|
typedef pthread_mutex_t __libcpp_mutex_t;
|
|
|
+#define _LIBCPP_MUTEX_INITIALIZER PTHREAD_MUTEX_INITIALIZER
|
|
|
+
|
|
|
+_LIBCPP_THREAD_ABI_VISIBILITY
|
|
|
+int __libcpp_recursive_mutex_init(__libcpp_mutex_t* __m);
|
|
|
+_LIBCPP_THREAD_ABI_VISIBILITY
|
|
|
+int __libcpp_mutex_lock(__libcpp_mutex_t* __m);
|
|
|
+_LIBCPP_THREAD_ABI_VISIBILITY
|
|
|
+int __libcpp_mutex_trylock(__libcpp_mutex_t* __m);
|
|
|
+_LIBCPP_THREAD_ABI_VISIBILITY
|
|
|
+int __libcpp_mutex_unlock(__libcpp_mutex_t* __m);
|
|
|
+_LIBCPP_THREAD_ABI_VISIBILITY
|
|
|
+int __libcpp_mutex_destroy(__libcpp_mutex_t* __m);
|
|
|
+
|
|
|
+// Condition variable
|
|
|
+typedef pthread_cond_t __libcpp_condvar_t;
|
|
|
+#define _LIBCPP_CONDVAR_INITIALIZER PTHREAD_COND_INITIALIZER
|
|
|
+_LIBCPP_THREAD_ABI_VISIBILITY
|
|
|
+int __libcpp_condvar_signal(__libcpp_condvar_t* __cv);
|
|
|
+_LIBCPP_THREAD_ABI_VISIBILITY
|
|
|
+int __libcpp_condvar_broadcast(__libcpp_condvar_t* __cv);
|
|
|
+_LIBCPP_THREAD_ABI_VISIBILITY
|
|
|
+int __libcpp_condvar_wait(__libcpp_condvar_t* __cv, __libcpp_mutex_t* __m);
|
|
|
+_LIBCPP_THREAD_ABI_VISIBILITY
|
|
|
+int __libcpp_condvar_timedwait(__libcpp_condvar_t* __cv, __libcpp_mutex_t* __m, timespec* __ts);
|
|
|
+_LIBCPP_THREAD_ABI_VISIBILITY
|
|
|
+int __libcpp_condvar_destroy(__libcpp_condvar_t* __cv);
|
|
|
+
|
|
|
+// Thread id
|
|
|
+typedef pthread_t __libcpp_thread_id;
|
|
|
+_LIBCPP_THREAD_ABI_VISIBILITY
|
|
|
+bool __libcpp_thread_id_equal(__libcpp_thread_id t1, __libcpp_thread_id t2);
|
|
|
+_LIBCPP_THREAD_ABI_VISIBILITY
|
|
|
+bool __libcpp_thread_id_less(__libcpp_thread_id t1, __libcpp_thread_id t2);
|
|
|
+
|
|
|
+// Thread
|
|
|
+typedef pthread_t __libcpp_thread_t;
|
|
|
+_LIBCPP_THREAD_ABI_VISIBILITY
|
|
|
+int __libcpp_thread_create(__libcpp_thread_t* __t, void* (*__func)(void*), void* __arg);
|
|
|
+_LIBCPP_THREAD_ABI_VISIBILITY
|
|
|
+__libcpp_thread_id __libcpp_thread_get_current_id();
|
|
|
+_LIBCPP_THREAD_ABI_VISIBILITY
|
|
|
+__libcpp_thread_id __libcpp_thread_get_id(const __libcpp_thread_t* __t);
|
|
|
+_LIBCPP_THREAD_ABI_VISIBILITY
|
|
|
+int __libcpp_thread_join(__libcpp_thread_t* __t);
|
|
|
+_LIBCPP_THREAD_ABI_VISIBILITY
|
|
|
+int __libcpp_thread_detach(__libcpp_thread_t* __t);
|
|
|
+_LIBCPP_THREAD_ABI_VISIBILITY
|
|
|
+void __libcpp_thread_yield();
|
|
|
+
|
|
|
+// Thread local storage
|
|
|
+typedef pthread_key_t __libcpp_tls_key;
|
|
|
+_LIBCPP_THREAD_ABI_VISIBILITY
|
|
|
+int __libcpp_tls_create(__libcpp_tls_key* __key, void (*__at_exit)(void*));
|
|
|
+_LIBCPP_THREAD_ABI_VISIBILITY
|
|
|
+void* __libcpp_tls_get(__libcpp_tls_key __key);
|
|
|
+_LIBCPP_THREAD_ABI_VISIBILITY
|
|
|
+void __libcpp_tls_set(__libcpp_tls_key __key, void* __p);
|
|
|
+
|
|
|
+#if defined(_LIBCPP_HAS_THREAD_API_PTHREAD) || defined(_LIBCPP_BUILDING_EXTERNAL_THREADS)
|
|
|
|
|
|
-inline _LIBCPP_ALWAYS_INLINE
|
|
|
int __libcpp_recursive_mutex_init(__libcpp_mutex_t* __m)
|
|
|
{
|
|
|
pthread_mutexattr_t attr;
|
|
@@ -59,144 +122,112 @@ int __libcpp_recursive_mutex_init(__libcpp_mutex_t* __m)
|
|
|
return 0;
|
|
|
}
|
|
|
|
|
|
-inline _LIBCPP_ALWAYS_INLINE
|
|
|
int __libcpp_mutex_lock(__libcpp_mutex_t* __m)
|
|
|
{
|
|
|
return pthread_mutex_lock(__m);
|
|
|
}
|
|
|
|
|
|
-inline _LIBCPP_ALWAYS_INLINE
|
|
|
int __libcpp_mutex_trylock(__libcpp_mutex_t* __m)
|
|
|
{
|
|
|
return pthread_mutex_trylock(__m);
|
|
|
}
|
|
|
|
|
|
-inline _LIBCPP_ALWAYS_INLINE
|
|
|
int __libcpp_mutex_unlock(__libcpp_mutex_t* __m)
|
|
|
{
|
|
|
return pthread_mutex_unlock(__m);
|
|
|
}
|
|
|
|
|
|
-inline _LIBCPP_ALWAYS_INLINE
|
|
|
int __libcpp_mutex_destroy(__libcpp_mutex_t* __m)
|
|
|
{
|
|
|
return pthread_mutex_destroy(__m);
|
|
|
}
|
|
|
|
|
|
// Condition variable
|
|
|
-#define _LIBCPP_CONDVAR_INITIALIZER PTHREAD_COND_INITIALIZER
|
|
|
-typedef pthread_cond_t __libcpp_condvar_t;
|
|
|
-
|
|
|
-inline _LIBCPP_ALWAYS_INLINE
|
|
|
int __libcpp_condvar_signal(__libcpp_condvar_t* __cv)
|
|
|
{
|
|
|
return pthread_cond_signal(__cv);
|
|
|
}
|
|
|
|
|
|
-inline _LIBCPP_ALWAYS_INLINE
|
|
|
int __libcpp_condvar_broadcast(__libcpp_condvar_t* __cv)
|
|
|
{
|
|
|
return pthread_cond_broadcast(__cv);
|
|
|
}
|
|
|
|
|
|
-inline _LIBCPP_ALWAYS_INLINE
|
|
|
int __libcpp_condvar_wait(__libcpp_condvar_t* __cv, __libcpp_mutex_t* __m)
|
|
|
{
|
|
|
return pthread_cond_wait(__cv, __m);
|
|
|
}
|
|
|
|
|
|
-inline _LIBCPP_ALWAYS_INLINE
|
|
|
int __libcpp_condvar_timedwait(__libcpp_condvar_t* __cv, __libcpp_mutex_t* __m, timespec* __ts)
|
|
|
{
|
|
|
return pthread_cond_timedwait(__cv, __m, __ts);
|
|
|
}
|
|
|
|
|
|
-inline _LIBCPP_ALWAYS_INLINE
|
|
|
int __libcpp_condvar_destroy(__libcpp_condvar_t* __cv)
|
|
|
{
|
|
|
return pthread_cond_destroy(__cv);
|
|
|
}
|
|
|
|
|
|
-// Thread id
|
|
|
-typedef pthread_t __libcpp_thread_id;
|
|
|
-
|
|
|
// Returns non-zero if the thread ids are equal, otherwise 0
|
|
|
-inline _LIBCPP_ALWAYS_INLINE
|
|
|
bool __libcpp_thread_id_equal(__libcpp_thread_id t1, __libcpp_thread_id t2)
|
|
|
{
|
|
|
return pthread_equal(t1, t2) != 0;
|
|
|
}
|
|
|
|
|
|
// Returns non-zero if t1 < t2, otherwise 0
|
|
|
-inline _LIBCPP_ALWAYS_INLINE
|
|
|
bool __libcpp_thread_id_less(__libcpp_thread_id t1, __libcpp_thread_id t2)
|
|
|
{
|
|
|
return t1 < t2;
|
|
|
}
|
|
|
|
|
|
// Thread
|
|
|
-typedef pthread_t __libcpp_thread_t;
|
|
|
-
|
|
|
-inline _LIBCPP_ALWAYS_INLINE
|
|
|
int __libcpp_thread_create(__libcpp_thread_t* __t, void* (*__func)(void*), void* __arg)
|
|
|
{
|
|
|
return pthread_create(__t, 0, __func, __arg);
|
|
|
}
|
|
|
|
|
|
-inline _LIBCPP_ALWAYS_INLINE
|
|
|
__libcpp_thread_id __libcpp_thread_get_current_id()
|
|
|
{
|
|
|
return pthread_self();
|
|
|
}
|
|
|
|
|
|
-inline _LIBCPP_ALWAYS_INLINE
|
|
|
__libcpp_thread_id __libcpp_thread_get_id(const __libcpp_thread_t* __t)
|
|
|
{
|
|
|
return *__t;
|
|
|
}
|
|
|
|
|
|
-inline _LIBCPP_ALWAYS_INLINE
|
|
|
int __libcpp_thread_join(__libcpp_thread_t* __t)
|
|
|
{
|
|
|
return pthread_join(*__t, 0);
|
|
|
}
|
|
|
|
|
|
-inline _LIBCPP_ALWAYS_INLINE
|
|
|
int __libcpp_thread_detach(__libcpp_thread_t* __t)
|
|
|
{
|
|
|
return pthread_detach(*__t);
|
|
|
}
|
|
|
|
|
|
-inline _LIBCPP_ALWAYS_INLINE
|
|
|
void __libcpp_thread_yield()
|
|
|
{
|
|
|
sched_yield();
|
|
|
}
|
|
|
|
|
|
// Thread local storage
|
|
|
-typedef pthread_key_t __libcpp_tl_key;
|
|
|
-
|
|
|
-inline _LIBCPP_ALWAYS_INLINE
|
|
|
-int __libcpp_tl_create(__libcpp_tl_key* __key, void (*__at_exit)(void*))
|
|
|
+int __libcpp_tls_create(__libcpp_tls_key* __key, void (*__at_exit)(void*))
|
|
|
{
|
|
|
return pthread_key_create(__key, __at_exit);
|
|
|
}
|
|
|
|
|
|
-inline _LIBCPP_ALWAYS_INLINE
|
|
|
-void* __libcpp_tl_get(__libcpp_tl_key __key)
|
|
|
+void* __libcpp_tls_get(__libcpp_tls_key __key)
|
|
|
{
|
|
|
return pthread_getspecific(__key);
|
|
|
}
|
|
|
|
|
|
-inline _LIBCPP_ALWAYS_INLINE
|
|
|
-void __libcpp_tl_set(__libcpp_tl_key __key, void* __p)
|
|
|
+void __libcpp_tls_set(__libcpp_tls_key __key, void* __p)
|
|
|
{
|
|
|
pthread_setspecific(__key, __p);
|
|
|
}
|
|
|
|
|
|
-#else // !_LIBCPP_HAS_THREAD_API_PTHREAD
|
|
|
- #error "No thread API selected."
|
|
|
-#endif
|
|
|
+#endif // _LIBCPP_HAS_THREAD_API_PTHREAD || _LIBCPP_BUILDING_EXTERNAL_THREADS
|
|
|
|
|
|
_LIBCPP_END_NAMESPACE_STD
|
|
|
|