mirrors/lz4
0
0
Fork 0
mirror of https://github.com/lz4/lz4.git synced 2024-11-23 18:04:05 +08:00
Code Issues Packages Projects Releases Wiki Activity

queueLock no longer required

Browse Source
This commit is contained in:
Yann Collet 2024-07-05 16:45:07 -07:00
parent 7183fe9e04
commit b4e3708823
1 changed files with 0 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
programs/threadpool.c
View File

@ -80,7 +80,6 @@ typedef struct TPOOL_ctx_s {
HANDLE workerThreads[TPOOL_MAX_WORKERS];
int numWorkers;
int queueSize;
CRITICAL_SECTION queueLock; // Now only for pending job count
__LONG32 numPendingJobs;
HANDLE jobSemaphore; // For queue size control
} TPOOL_ctx;
@ -103,7 +102,6 @@ void TPOOL_free(TPOOL_ctx* ctx) {
CloseHandle(ctx->completionPort);
// Clean up synchronization objects
DeleteCriticalSection(&ctx->queueLock);
CloseHandle(ctx->jobSemaphore);
free(ctx);
@ -173,7 +171,6 @@ TPOOL_ctx* TPOOL_create(int nbThreads, int queueSize)
}
// Initialize other members (no changes here)
InitializeCriticalSection(&ctx->queueLock);
ctx->queueSize = queueSize;
ctx->numPendingJobs = 0;
ctx->jobSemaphore = CreateSemaphore(NULL, 0, queueSize, NULL);