mirrors/lz4
0
0
Fork 0
mirror of https://github.com/lz4/lz4.git synced 2024-11-27 03:48:08 +08:00
Code Issues Packages Projects Releases Wiki Activity

minor completion port update

Browse Source 
for consistency with pthread implementation
This commit is contained in:
Yann Collet 2024-07-07 13:59:44 -07:00
parent cfdb8ac60b
commit 32f7fd3f38
1 changed files with 4 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
programs/threadpool.c
View File

@ -143,11 +143,8 @@ TPool* TPool_create(int nbWorkers, int queueSize)
TPool* pool;
/* parameters sanitization */
if (nbWorkers <= 0 || queueSize <= 0) {
return NULL;
}
if (nbWorkers>LZ4_NBWORKERS_MAX)
nbWorkers=LZ4_NBWORKERS_MAX;
if (nbWorkers <= 0 || queueSize <= 0) return NULL;
if (nbWorkers>LZ4_NBWORKERS_MAX) nbWorkers=LZ4_NBWORKERS_MAX;
pool = calloc(1, sizeof(TPool));
if (!pool) return NULL;
@ -188,7 +185,7 @@ _cleanup:
void TPool_submitJob(TPool* pool, void (*job_function)(void*), void* arg)
{
if (!pool || !job_function) return;
assert(pool);
/* Atomically increment pending jobs and check for overflow */
WaitForSingleObject(pool->jobSlotAvail, INFINITE);
@ -204,7 +201,7 @@ void TPool_submitJob(TPool* pool, void (*job_function)(void*), void* arg)
void TPool_jobsCompleted(TPool* pool)
{
if (!pool) return;
assert(pool);
WaitForSingleObject(pool->allJobsCompleted, INFINITE);
}