Function thpool_destroy

src/util/thpool/thpool.c:201–229

Destroy the threadpool */

/* Destroy the threadpool */
void thpool_destroy(thpool_* thpool_p) {
	/* No need to destory if it's NULL */
	if (thpool_p == NULL) {
		return;
	}

	const uint32_t threads_total = thpool_p->num_threads_alive;

	/* Make the threads leave their main loops. */
	threads_keepalive = 0;

	// Wake up the threads so that they exit and will become ready to be
	// destroyed.
	while(thpool_p->num_threads_alive) {
		bsem_post_all(thpool_p->jobqueue.has_jobs);
	}

	// Destroy the threads.
	for (size_t i = 0; i < threads_total; ++i) {
		ASSERT(pthread_join(thpool_p->threads[i]->pthread, NULL) == 0);
		thread_destroy(thpool_p->threads[i]);
	}
	rm_free(thpool_p->threads);

	/* Job queue cleanup */
	jobqueue_destroy(&thpool_p->jobqueue);

	rm_free(thpool_p);
}

/* Pause all threads in threadpool */
void thpool_pause(thpool_* thpool_p) {