Tema

src/os_threadpool.c

@@ -41,7 +41,7 @@ void enqueue_task(os_threadpool_t *tp, os_task_t *t)
 	/* TODO: Enqueue task to the shared task queue. Use synchronization. */
 	pthread_mutex_lock(&tp->mutexCoada);
 	list_add_tail(&tp->head, &t->list);
-	pthread_cond_signal(&tp->Wait);
+	pthread_cond_broadcast(&tp->Wait);
 	pthread_mutex_unlock(&tp->mutexCoada);
 }
 
@@ -114,7 +114,7 @@ void wait_for_completion(os_threadpool_t *tp)
 		pthread_cond_wait(&tp->WakeUp, &tp->mutexCoada);
 	tp->stop = 1;
 	while (tp->threadsOut < tp->num_threads) {
-		pthread_cond_signal(&tp->Wait);
+		pthread_cond_broadcast(&tp->Wait);
 		pthread_cond_wait(&tp->WakeUp, &tp->mutexCoada);
 	}
 	/* Join all worker threads. */