Tema

src/os_threadpool.c

@@ -115,12 +115,10 @@ void wait_for_completion(os_threadpool_t *tp)
 		pthread_cond_wait(&tp->WakeUp, &tp->mutexCoada);
 	tp->stop = 1;
 	pthread_mutex_unlock(&tp->mutexCoada);
-	pthread_mutex_lock(&tp->mutexCoada);
 	while (tp->threadsOut < tp->num_threads) {
 		pthread_cond_broadcast(&tp->Wait);
 		pthread_cond_wait(&tp->WakeUp, &tp->mutexCoada);
 	}
-	pthread_mutex_unlock(&tp->mutexCoada);
 	/* Join all worker threads. */
 	for (unsigned int i = 0; i < tp->num_threads; i++)
 		pthread_join(tp->threads[i], NULL);