Function thread_do

src/util/thpool/thpool.c:391–451

What each thread is doing * * In principle this is an endless loop. The only time this loop gets interuppted is once * thpool_destroy() is invoked or the program exits. * * @param thread thread that will run this function * @return nothing */

* @return nothing
*/
static void *thread_do(struct thread *thread_p) {

	/* Set thread name for profiling and debuging */
	char thread_name[128] = {0};
	sprintf(thread_name, "thread-pool-%s-%d", thread_p->thpool_p->name, thread_p->id);

#if defined(__linux__)
	/* Use prctl instead to prevent using _GNU_SOURCE flag and implicit declaration */
	prctl(PR_SET_NAME, thread_name);
#elif defined(__APPLE__) && defined(__MACH__)
	pthread_setname_np(thread_name);
#else
	err("thread_do(): pthread_setname_np is not supported on this system");
#endif

	/* Assure all threads have been created before starting serving */
	thpool_* thpool_p = thread_p->thpool_p;

	/* Register signal handler */
	struct sigaction act;
	sigemptyset(&act.sa_mask);
	act.sa_flags = 0;
	act.sa_handler = thread_hold;
	if(sigaction(SIGUSR2, &act, NULL) == -1) {
		err("thread_do(): cannot handle SIGUSR1");
	}

	/* Mark thread as alive (initialized) */
	++thpool_p->num_threads_alive;

	while(threads_keepalive) {

		bsem_wait(thpool_p->jobqueue.has_jobs);

		if(threads_keepalive) {
			++thpool_p->num_threads_working;

			/* Read job from queue and execute it */
			void (*func_buff)(void *);
			void *arg_buff;
			job *job_p = jobqueue_pull(&thpool_p->jobqueue);
			if(job_p) {
				func_buff = job_p->function;
				arg_buff = job_p->arg;
				func_buff(arg_buff);
				rm_free(job_p);
			}

			--thpool_p->num_threads_working;
			pthread_mutex_lock(&thpool_p->thcount_lock);
			if (!thpool_p->num_threads_working) {
				pthread_cond_signal(&thpool_p->threads_all_idle);
			}
			pthread_mutex_unlock(&thpool_p->thcount_lock);
		}
	}

	--thpool_p->num_threads_alive;