linux线程 | 条件变量、信号量-ag九游会j9官方网站

#include

/*超时等待*/

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

/*条件变量阻塞等待*/

int pthread_cond_wait(pthread_cond_t *restrict cond, pthread_mutex_t *restrict mutex);

#include

int pthread_cond_destroy(pthread_cond_t *cond);

int pthread_cond_init(pthread_cond_t *restrict cond, const pthread_condattr_t *restrict attr);

pthread_cond_t cond = pthread_cond_initializer;

#include

/*唤醒阻塞在条件变量cond上的全部线程*/

int pthread_cond_broadcast(pthread_cond_t *cond);

/*唤醒至少一个阻塞在条件上的线程*/

int pthread_cond_signal(pthread_cond_t *cond);

#include

#include

#include

#include

pthread_mutex_t mutex = pthread_mutex_initializer;

pthread_cond_t cond = pthread_cond_initializer;

int gstart = 100;

typedef struct datainfo

{

int data;

struct datainfo* next;

}datainfo;

datainfo* head = null;

void* producer_th(void* arg)

{

while(1)

{

datainfo* node = malloc(sizeof(datainfo));

node->data = gstart ;

printf("thread: %s, tid: %lu, data: %d\n", __function__,\

pthread_self(), node->data);

pthread_mutex_lock(&mutex);

node->next = head;

head = node;

pthread_mutex_unlock(&mutex);

pthread_cond_signal(&cond);

sleep(rand()%3);

}

}

void* consumer_th(void* arg)

{

while(1)

{

datainfo* node = null;

pthread_mutex_lock(&mutex);

while(head == null)