Function queue_free

lib_fiber/c/src/common/queue.c:70–111

}

void queue_free(QUEUE *que, QUEUE_FREE_FN free_fn)
{
	QUEUE_ITEM *qi;
	int   status;

	if (que == NULL) {
		return;
	}

	if (que->check_owner && thread_self() != que->owner) {
		msg_error("%s: cur tid(%lu) != owner(%lu)!", __FUNCTION__,
			thread_self(), que->owner);
		return;
	}

	que->quit = 1;
	status = pthread_mutex_lock(&que->lock);
	if (status != 0) {
		msg_error("%s: lock error(%s)", __FUNCTION__, last_serror());
	}

	while (1) {
		qi = que->first;
		if (qi == NULL) {
			break;
		}
		que->first = qi->next;
		if (free_fn != NULL) {
			free_fn(qi->data);
		}
		free(qi);
	}

	status = pthread_mutex_unlock(&que->lock);
	if (status != 0) {
		msg_error("%s: lock error(%s)", __FUNCTION__, last_serror());
	}

	pthread_mutex_destroy(&que->lock);
	pthread_cond_destroy(&que->cond);
	free(que);
}

static int queue_wait(QUEUE *que, const struct timespec *ptimeo)
{