zlgopen/awtk
1
0
Fork 0
mirror of https://github.com/zlgopen/awtk.git synced 2025-05-09 03:51:08 +08:00
Code Issues Packages Projects Releases Wiki Activity

improve semaphore

Browse Source
This commit is contained in:
lixianjing 2019-10-28 06:55:32 +08:00
parent 9c941b1c25
commit e47f152f32
2 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/platforms/pc/semaphore.c
View File

@ -49,7 +49,11 @@ tk_semaphore_t* tk_semaphore_create(uint32_t value, const char* name) {
semaphore = NULL; semaphore = NULL;
} }
#elif defined(WIN32) #elif defined(WIN32)
semaphore->sem = CreateSemaphore(NULL, MAX_RUNNUM, MAX_RUNNUM, name); semaphore->sem = CreateSemaphore(NULL, value, INT_MAX, name);
if (semaphore->sem == NULL) {
TKMEM_FREE(semaphore);
semaphore = NULL;
}
#endif /*HAS_PTHREAD*/ #endif /*HAS_PTHREAD*/
return semaphore; return semaphore;
@ -86,7 +90,7 @@ ret_t tk_semaphore_post(tk_semaphore_t* semaphore) {
#ifdef HAS_PTHREAD #ifdef HAS_PTHREAD
return_value_if_fail(sem_post(semaphore->sem) == 0, RET_FAIL); return_value_if_fail(sem_post(semaphore->sem) == 0, RET_FAIL);
#elif defined(WIN32) #elif defined(WIN32)
ReleaseSemaphore(semaphore->sem, 1, NULL); return_value_if_fail(ReleaseSemaphore(semaphore->sem, 1, NULL), RET_FAIL);
#endif /*HAS_PTHREAD*/ #endif /*HAS_PTHREAD*/
return RET_OK; return RET_OK;

2
tests/semaphore_test.cc
View File

@ -13,7 +13,7 @@ static void* thread_entry(void* args) {
} }
TEST(Semaphore, basic) { TEST(Semaphore, basic) {
tk_semaphore_t* sem = tk_semaphore_create(1, "hello"); tk_semaphore_t* sem = tk_semaphore_create(0, "hello");
tk_thread_t* thread = tk_thread_create(thread_entry, sem); tk_thread_t* thread = tk_thread_create(thread_entry, sem);
tk_thread_start(thread); tk_thread_start(thread);