dany/libwebp
1
0
Fork 0
mirror of https://github.com/webmproject/libwebp.git synced 2025-08-28 06:42:27 +02:00
Code Issues Actions Packages Projects Releases Wiki Activity

Merge "Implement pthread_mutex_t using SRWLOCK on Windows" into main

Browse Source
This commit is contained in:
James Zern
2025-08-06 19:02:21 -07:00
committed by Gerrit Code Review
parent 6913049d6e 6680723e66
commit 4bcea04803
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/utils/thread_utils.c
View File

@@ -27,11 +27,11 @@ WEBP_ASSUME_UNSAFE_INDEXABLE_ABI
#include <windows.h> #include <windows.h>
typedef HANDLE pthread_t; typedef HANDLE pthread_t;
typedef CRITICAL_SECTION pthread_mutex_t;
#if _WIN32_WINNT < 0x0600 #if _WIN32_WINNT < 0x0600
#error _WIN32_WINNT must target Windows Vista / Server 2008 or newer. #error _WIN32_WINNT must target Windows Vista / Server 2008 or newer.
#endif #endif
typedef SRWLOCK pthread_mutex_t;
typedef CONDITION_VARIABLE pthread_cond_t; typedef CONDITION_VARIABLE pthread_cond_t;
#ifndef WINAPI_FAMILY_PARTITION #ifndef WINAPI_FAMILY_PARTITION
@@ -93,22 +93,22 @@ static int pthread_join(pthread_t thread, void** value_ptr) {
// Mutex // Mutex
static int pthread_mutex_init(pthread_mutex_t* const mutex, void* mutexattr) { static int pthread_mutex_init(pthread_mutex_t* const mutex, void* mutexattr) {
(void)mutexattr; (void)mutexattr;
InitializeCriticalSectionEx(mutex, /*dwSpinCount=*/0, /*Flags=*/0); InitializeSRWLock(mutex);
return 0; return 0;
} }
static int pthread_mutex_lock(pthread_mutex_t* const mutex) { static int pthread_mutex_lock(pthread_mutex_t* const mutex) {
EnterCriticalSection(mutex); AcquireSRWLockExclusive(mutex);
return 0; return 0;
} }
static int pthread_mutex_unlock(pthread_mutex_t* const mutex) { static int pthread_mutex_unlock(pthread_mutex_t* const mutex) {
LeaveCriticalSection(mutex); ReleaseSRWLockExclusive(mutex);
return 0; return 0;
} }
static int pthread_mutex_destroy(pthread_mutex_t* const mutex) { static int pthread_mutex_destroy(pthread_mutex_t* const mutex) {
DeleteCriticalSection(mutex); (void)mutex;
return 0; return 0;
} }
@@ -131,7 +131,7 @@ static int pthread_cond_signal(pthread_cond_t* const condition) {
static int pthread_cond_wait(pthread_cond_t* const condition, static int pthread_cond_wait(pthread_cond_t* const condition,
pthread_mutex_t* const mutex) { pthread_mutex_t* const mutex) {
const int ok = SleepConditionVariableCS(condition, mutex, INFINITE); const int ok = SleepConditionVariableSRW(condition, mutex, INFINITE, 0);
return !ok; return !ok;
} }