Tema

src/os_threadpool.c

@@ -90,15 +90,10 @@ static void *thread_loop_function(void *arg)
 
 	while (1) {
 		t = dequeue_task(tp);
-		pthread_mutex_lock(&tp->mutexCoada);
-		int ok = tp->stop;
-		pthread_mutex_unlock(&tp->mutexCoada);
-		if (ok)
+		if (t == NULL)
 			break;
-		if (t != NULL) {
-			t->action(t->argument);
-			destroy_task(t);
-		}
+		t->action(t->argument);
+		destroy_task(t);
 	}
 	pthread_mutex_lock(&tp->mutexCoada);
 	++tp->threadsOut;