fix parallel remove

turkman-linux · May 20, 2024 · cb793e9 · cb793e9
1 parent 43885fb
commit cb793e9
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/src/ccode/job.c b/src/ccode/job.c
@@ -1,5 +1,6 @@
 #include <stdio.h>
 #include <stdlib.h>
+#include <stdbool.h>
 #include <pthread.h>
 #include <string.h>
 #include <stdarg.h>
@@ -13,16 +14,21 @@ void* worker_thread(void* arg) {
             break;
         }
         int i;
+        bool e = false; /* search for job */
         for (i = 0; i < j->total; ++i) {
             if (j->jobs[i].callback != NULL) {
                 void (*callback)(void*, ...) = j->jobs[i].callback;
                 j->jobs[i].callback = NULL;
                 callback((void*)j->jobs[i].ctx, (void*)j->jobs[i].args);
                 j->finished++;
                 j->current--;
+                e = true;
                 break;
             }
         }
+        if(!e){
+            break;
+        }
     }
     pthread_exit(NULL);
 }