长安区建设局网站,新风格网站,没有网站可以做cpa广告么,深圳做营销网站的公司1.条件变量
条件变量是线程另一可用的同步机制。条件变量给多个线程提供了一个会合的场所。条件变量与互斥量一起使用时#xff0c;允许线程以无竞争的方式等待特定的条件发生。
条件本身是由互斥量保护的。线程在改变条件状态前必须首先锁住互斥量#xff0c;其他线程在获…1.条件变量
条件变量是线程另一可用的同步机制。条件变量给多个线程提供了一个会合的场所。条件变量与互斥量一起使用时允许线程以无竞争的方式等待特定的条件发生。
条件本身是由互斥量保护的。线程在改变条件状态前必须首先锁住互斥量其他线程在获得互斥量之前不会察觉到这种改变因为必须锁定互斥量以后才能计算条件。
条件变量使用之前必须首先初始化pthread_cond_t数据类型代表的条件变量可以用两种方式进行初始化可以把常量PTHREAD_COND_INITIALIZER赋给静态分配的条件变量但是如果条件变量是动态分配的可以使用pthread_cond_destroy函数对条件变量进行去除初始化deinitialize。
2.创建及销毁条件变量
函数原型
#include pthread.h
int pthread_cond_init(pthread_cond_t *restrict cond, const pthread_condattr_t *restrict attr);
int pthread_cond_destroy(pthread_cond_t cond);
// 返回若成功返回0否则返回错误编号参数说明
pthread_cond_init
cond指向要初始化的条件变量的指针。attr指向条件变量属性的指针可以为NULL。如果为NULL则使用默认属性。
返回值
如果成功返回0否则返回错误码。
3.等待
函数原型
#include pthread.h
int pthread_cond_wait(pthread_cond_t *restrict cond, pthread_mutex_t *restrict mutex);
int pthread_cond_timedwait(pthread_cond_t *restrict cond, pthread_mutex_t *restrict mutex, cond struct timespec *restrict timeout);
// 返回若成功返回0否则返回错误编号参数说明
pthread_cond_wait
cond指向要等待的条件变量的指针。mutex指向互斥锁的指针用于保护条件变量。
返回值
如果成功返回0否则返回错误码。
pthread_cond_timedwait 参数说明
cond指向要等待的条件变量的指针。mutex指向互斥锁的指针用于保护条件变量。abstime指向一个timespec结构体的指针表示等待的最长时间。如果设置为NULL则表示无限等待。
返回值
如果成功返回0否则返回错误码。 pthread_cond_wait等待条件变为真。如果在给定的时间内条件不能满足那么会生成一个代表一个出错码的返回变量。传递给pthread_cond_wait的互斥量对条件进行保护调用者把锁住的互斥量传给函数。函数把调用线程放到等待条件的线程列表上然后对互斥量解锁这两个操作都是原子操作。这样就关闭了条件检查和线程进入休眠状态等待条件改变这两个操作之间的时间通道这样线程就不会错过条件的任何变化。
pthread_cond_wait返回时互斥量再次被锁住。
pthread_cond_timedwait函数的工作方式与pthread_cond_wait函数类似只是多了一个timeout。timeout指定了等待的时间它是通过timespec结构指定。 4.触发函数原型
#include pthread.h
int pthread_cond_signal(pthread_cond_t cond);
int pthread_cond_broadcast(pthread_cond_t cond);
// 返回若成功返回0否则返回错误编号这两个函数可以用于通知线程条件已经满足。 pthread_cond_signal函数将唤醒等待该条件的某个线程而pthread_cond_broadcast函数将唤醒等待该条件的所有进程。 注意一定要在改变条件状态以后再给线程发信号。 代码
#includestdio.h
#includepthread.h
#include unistd.h
#includestdlib.h
int data 0;//定义一个全局变量data
pthread_mutex_t mutex; //还可以直接定义和初始化好 pthread_mutex_t mutex PTHREAD_MUTEX_INITIALIZER
pthread_cond_t cond; //pthread_cond_t cond PTHREAD_COND_INITIALIZER
void *func1(void *arg)
{static int cnt 0;while(1){pthread_cond_wait(cond,mutex);//收到信号printf(t1 tun\n);printf(t1线程拿到data:%d\n,data);data 0;sleep(1);if(cnt 3){printf(结束!\n);exit(1);//达到条件结束整个程序}}}
void *func2(void *arg)
{while(1){printf(线程t2拿到 data %d\n,data);pthread_mutex_lock(mutex);//先拿到互斥锁先运行data;if(data 3){pthread_cond_signal(cond);//达到条件向线程t1发送信号}pthread_mutex_unlock(mutex);sleep(1);}
}
int main()
{int ret;int param 100;pthread_t t1;pthread_t t2;pthread_mutex_init(mutex,NULL);pthread_cond_init(cond,NULL);//动态初始化条件变量ret pthread_create(t1,NULL,func1,(void *)param);//创建线程t1if(ret 0){// printf(main:创建线程t1成功!\n);}ret pthread_create(t2,NULL,func2,(void *)param);//创建线程t2if(ret 0){// printf(main:创建线程t2成功!\n);}pthread_join(t1,NULL);pthread_join(t2,NULL);pthread_mutex_destroy(mutex);pthread_cond_destroy(cond);return 0;
}
结果
