modif

src/os_threadpool.c

@@ -63,11 +63,9 @@ static int queue_is_empty(os_threadpool_t *tp)
 
 os_task_t *dequeue_task(os_threadpool_t *tp)
 {
-	os_task_t *t = NULL;
+	os_task_t *t;
 
 	/* TODO: Dequeue task from the shared task queue. Use synchronization. */
-	if (tp == NULL)
-		return NULL;
 	pthread_mutex_lock(&tp->mutexCoada);
 	pthread_cond_broadcast(&tp->WakeUp);
 	while (queue_is_empty(tp) && !tp->stop)
@@ -104,8 +102,7 @@ static void *thread_loop_function(void *arg)
 void wait_for_completion(os_threadpool_t *tp)
 {
 	/* TODO: Wait for all worker threads. Use synchronization. */
-	if (tp == NULL)
-		return;
+	pthread_mutex_lock(&tp->mutexCoada);
 	while (tp->verifProcessing())
 		pthread_cond_wait(&tp->WakeUp, &tp->mutexCoada);
 	tp->stop = 1;
@@ -113,6 +110,7 @@ void wait_for_completion(os_threadpool_t *tp)
 		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);