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

simpler execution expression

Browse Source
This commit is contained in:
Yann Collet 2024-07-07 11:55:53 -07:00
parent f0b29a973b
commit 50d541f9e3
1 changed files with 9 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
programs/threadpool.c
View File

@ -83,7 +83,8 @@ typedef struct TPOOL_ctx_s {
HANDLE allJobsCompleted; /* Event */
} TPOOL_ctx;
void TPOOL_free(TPOOL_ctx* ctx) {
void TPOOL_free(TPOOL_ctx* ctx)
{
if (!ctx) return;
/* Signal workers to exit by posting NULL completions */
@ -108,7 +109,8 @@ void TPOOL_free(TPOOL_ctx* ctx) {
free(ctx);
}
static DWORD WINAPI WorkerThread(LPVOID lpParameter) {
static DWORD WINAPI WorkerThread(LPVOID lpParameter)
{
TPOOL_ctx* ctx = (TPOOL_ctx*)lpParameter;
DWORD bytesTransferred;
ULONG_PTR completionKey;
@ -118,17 +120,13 @@ static DWORD WINAPI WorkerThread(LPVOID lpParameter) {
&bytesTransferred, &completionKey,
&overlapped, INFINITE)) {
if (overlapped == NULL) {
/* End signal */
break;
}
/* End signal */
if (overlapped == NULL) { break; }
{ /* Execute job */
void (*job_function)(void*) = (void (*)(void*))completionKey;
job_function(overlapped);
}
/* Execute job */
((void (*)(void*))completionKey)(overlapped);
/* Signal job completion and decrement counter */
/* Signal job completion */
if (InterlockedDecrement(&ctx->nbPendingJobs) == 0) {
SetEvent(ctx->allJobsCompleted);
}