int pthread_cond_wait(pthread_cond_t *cond, pthread_mutex_t *mutex)
int pthread_cond_timedwait(pthread_cond_t *cond, pthread_mutex_t *mutex, const struct timespec *abstime)

#include "pthread.h"
#include "unistd.h"
#include "stdio.h"
#include "stdlib.h"
#include "string.h"struct _Node
{int number;struct _Node *next;
};
typedef struct _Node Node;Node *head;/*信号量和条件变量*/
static pthread_mutex_t mtx = PTHREAD_MUTEX_INITIALIZER;
static pthread_cond_t cond = PTHREAD_COND_INITIALIZER;/*线程异常时处理函数*/
static void cleanup_handler(void *arg)
{printf("cleanup_handler\n");free(arg);(void)pthread_mutex_unlock(&mtx);
}/*
pthread_cleanup_push注册一个回调函数，如果你的线程在对应的pthread_cleanup_pop之前异常退出(return是正常退出，其他是异常)，那么系统就会执行这个回调函数(回调函数要做什么你自己决定)。但是如果在pthread_cleanup_pop之前没有异常退出，pthread_cleanup_pop就把对应的回调函数取消了
*/
static void* thread_func(void *arg)
{Node *p = NULL;printf("in thread_func()\n");/*注册线程异常处理函数*/pthread_cleanup_push(cleanup_handler, p);while (1){pthread_mutex_lock(&mtx);while (NULL != head){/*如果条件不满足，则挂起*/pthread_cond_wait(&cond, &mtx);p = head;printf("Got %d from front of queue\n",p->number);free(p);pthread_mutex_unlock(&mtx);}}/*清空线程异常处理函数*/pthread_cleanup_pop(0);return 0;
}int main()
{pthread_t tid;int i;Node *p;pthread_create(&tid, NULL, thread_func, NULL);for(i = 0; i < 10; i++){printf("int main():%d", i);p = (Node*)malloc(sizeof(Node));p->number = i;pthread_mutex_lock(&mtx);p->next = head;head = p;/*通知条件OK了*/pthread_cond_signal(&cond);pthread_mutex_unlock(&mtx);sleep(1);}printf("thread 1 wanna end then cancel thread2.\n");pthread_cancel(tid);pthread_join(tid, NULL);printf("All done\n");return 0;
}

int main():0in thread_func()
int main():1Got 1 from front of queue
int main():2Got 2 from front of queue
int main():3Got 3 from front of queue
int main():4Got 4 from front of queue
int main():5Got 5 from front of queue
int main():6Got 6 from front of queue
int main():7Got 7 from front of queue
int main():8Got 8 from front of queue
int main():9Got 9 from front of queue
thread 1 wanna end then cancel thread2.
cleanup_handler
All done