static void destroy_worker_thread(comp_thread_ctxt_t *thd){

	pthread_join(thd->id, NULL);

	my_free(thd->to);

}

static comp_thread_ctxt_t * create_worker_threads(uint n){

	for (i = 0; i < n; i++) {

		if (pthread_mutex_init(&thd->data_mutex, NULL) ||

		    pthread_cond_init(&thd->avail_cond, NULL) ||

		    pthread_cond_init(&thd->data_cond, NULL) ||

		    pthread_cond_init(&thd->done_cond, NULL)) {

			goto err;     

		}

		if (pthread_create(&thd->id, NULL, compress_worker_thread_func,

				   thd)) {

			msg("compress: pthread_create() failed: "

			    "errno = %d", errno);

			goto err;

		}

	}

	return threads;

err:

	for (; i; i--) {

		destroy_worker_thread(threads + i);

	}

	my_free(threads);

	return NULL;

}