25 #elif !FOLLY_HAVE_PTHREAD 34 #define PTHREAD_CREATE_JOINABLE 0 35 #define PTHREAD_CREATE_DETACHED 1 37 #define PTHREAD_MUTEX_NORMAL 0 38 #define PTHREAD_MUTEX_RECURSIVE 1 39 #define PTHREAD_MUTEX_DEFAULT PTHREAD_MUTEX_NORMAL 41 #define _POSIX_TIMEOUTS 200112L 44 namespace portability {
46 struct pthread_attr_t {
51 int pthread_attr_init(pthread_attr_t* attr);
52 int pthread_attr_setdetachstate(pthread_attr_t* attr,
int state);
53 int pthread_attr_setstacksize(pthread_attr_t* attr,
size_t kb);
55 namespace pthread_detail {
57 HANDLE handle{INVALID_HANDLE_VALUE};
66 int pthread_equal(pthread_t threadA, pthread_t threadB);
69 const pthread_attr_t* attr,
70 void* (*start_routine)(
void*),
72 pthread_t pthread_self();
73 int pthread_join(pthread_t thread,
void** exitCode);
75 HANDLE pthread_getw32threadhandle_np(pthread_t thread);
76 DWORD pthread_getw32threadid_np(pthread_t thread);
78 int pthread_setschedparam(
81 const sched_param* param);
83 struct pthread_mutexattr_t {
86 int pthread_mutexattr_init(pthread_mutexattr_t* attr);
87 int pthread_mutexattr_destroy(pthread_mutexattr_t* attr);
88 int pthread_mutexattr_settype(pthread_mutexattr_t* attr,
int type);
90 using pthread_mutex_t =
struct pthread_mutex_t_*;
91 int pthread_mutex_init(pthread_mutex_t*
mutex,
const pthread_mutexattr_t* attr);
92 int pthread_mutex_destroy(pthread_mutex_t*
mutex);
93 int pthread_mutex_lock(pthread_mutex_t*
mutex);
94 int pthread_mutex_trylock(pthread_mutex_t*
mutex);
95 int pthread_mutex_unlock(pthread_mutex_t*
mutex);
96 int pthread_mutex_timedlock(
97 pthread_mutex_t*
mutex,
98 const timespec* abs_timeout);
100 using pthread_rwlock_t =
struct pthread_rwlock_t_*;
105 int pthread_rwlock_init(pthread_rwlock_t* rwlock,
const void* attr);
106 int pthread_rwlock_destroy(pthread_rwlock_t* rwlock);
107 int pthread_rwlock_rdlock(pthread_rwlock_t* rwlock);
108 int pthread_rwlock_tryrdlock(pthread_rwlock_t* rwlock);
109 int pthread_rwlock_timedrdlock(
110 pthread_rwlock_t* rwlock,
111 const timespec* abs_timeout);
112 int pthread_rwlock_wrlock(pthread_rwlock_t* rwlock);
113 int pthread_rwlock_trywrlock(pthread_rwlock_t* rwlock);
114 int pthread_rwlock_timedwrlock(
115 pthread_rwlock_t* rwlock,
116 const timespec* abs_timeout);
117 int pthread_rwlock_unlock(pthread_rwlock_t* rwlock);
119 using pthread_cond_t =
struct pthread_cond_t_*;
123 int pthread_cond_init(pthread_cond_t* cond,
const void* attr);
124 int pthread_cond_destroy(pthread_cond_t* cond);
125 int pthread_cond_wait(pthread_cond_t* cond, pthread_mutex_t*
mutex);
126 int pthread_cond_timedwait(
127 pthread_cond_t* cond,
128 pthread_mutex_t*
mutex,
129 const timespec* abstime);
130 int pthread_cond_signal(pthread_cond_t* cond);
131 int pthread_cond_broadcast(pthread_cond_t* cond);
135 using pthread_key_t =
void*;
137 int pthread_key_create(pthread_key_t* key,
void (*destructor)(
void*));
138 int pthread_key_delete(pthread_key_t key);
139 void* pthread_getspecific(pthread_key_t key);
140 int pthread_setspecific(pthread_key_t key,
const void*
value);
145 using namespace folly::portability::pthread;
static constexpr int kb(int kilos)
—— Concurrent Priority Queue Implementation ——
requires E e noexcept(noexcept(s.error(std::move(e))))
uint64_t value(const typename LockFreeRingBuffer< T, Atom >::Cursor &rbcursor)