Function thpool_init

src/util/thpool/thpool.c:111–169

Initialise thread pool */

/* Initialise thread pool */
struct thpool_ *thpool_init(int num_threads, const char *name) {

	threads_on_hold = 0;
	threads_keepalive = 1;

	if(num_threads < 0) {
		num_threads = 0;
	}

	/* Make new thread pool */
	thpool_* thpool_p;
	thpool_p = (struct thpool_*)rm_calloc(1, sizeof(struct thpool_));
	if(thpool_p == NULL) {
		err("thpool_init(): Could not allocate memory for thread pool\n");
		return NULL;
	}
	if(name == NULL) {
		err("thpool_init(): missing thread pool name\n");
		return NULL;
	}

	thpool_p->name = name;
	thpool_p->num_threads_alive = 0;
	thpool_p->num_threads_working = 0;

	/* Initialise the job queue */
	if(jobqueue_init(&thpool_p->jobqueue) == -1) {
		err("thpool_init(): Could not allocate memory for job queue\n");
		rm_free(thpool_p);
		return NULL;
	}

	/* Make threads in pool */
	thpool_p->threads = (struct thread **)rm_calloc(num_threads, sizeof(struct thread *));
	if(thpool_p->threads == NULL) {
		err("thpool_init(): Could not allocate memory for threads\n");
		jobqueue_destroy(&thpool_p->jobqueue);
		rm_free(thpool_p);
		return NULL;
	}

	pthread_mutex_init(&(thpool_p->thcount_lock), NULL);
	pthread_cond_init(&thpool_p->threads_all_idle, NULL);

	/* Thread init */
	int n;
	for(n = 0; n < num_threads; n++) {
		thread_init(thpool_p, &thpool_p->threads[n], n);
#if THPOOL_DEBUG
		printf("THPOOL_DEBUG: Created thread %d in pool \n", n);
#endif
	}

	/* Wait for threads to initialize */
	while(thpool_p->num_threads_alive != num_threads) {
	}

	return thpool_p;