我正在尝试实现这个简单的示例,说明如何使用pthread库同步线程:
#include <iostream>
#include <pthread.h>
using namespace std ;
static pthread_mutex_t locker;
pthread_cond_t cond;
volatile bool ok=false;
void *func2(void *data)
{
int i;
for(i=0;i<100;i++)
{
pthread_mutex_lock (&locker);
cout << "1";
pthread_mutex_unlock(&locker);
if(i==10)
{
ok=true;
pthread_cond_signal(&cond);
}
}
pthread_exit(0);
}
void *fun1(void *data)
{
int i;
for(i=0;i<100;i++)
{
if(ok==false){
pthread_cond_wait(&cond, &locker);
}
pthread_mutex_lock (&locker);
cout << "2";
pthread_mutex_unlock(&locker);
}
pthread_exit(0);
}
int main(void)
{
pthread_t thread1, thread2;
void *retour_thread;
pthread_mutex_init (&locker, NULL);
pthread_cond_init(&cond, NULL);
if(pthread_create (&thread1, NULL, fun1, NULL) < 0)
{
cout << "problem thread";
exit(1);
}
if(pthread_create (&thread2, NULL, func2, NULL) < 0)
{
cout << "problem thread";
exit(1);
}
(void)pthread_join(thread1,&retour_thread);
(void)pthread_join(thread2,&retour_thread);
return 0;
}
我应该看到的是func1等到条件(ok == true)之后再处理func2 ...但是我得到的是不可预测的并且没有同步!!!
任何帮助和感谢提前
最佳答案
您需要在调用pthread_cond_wait之前获取互斥锁,并在pthread_cond_wait返回之后,重新获取该互斥锁。您的fun1()应该类似于:
void *fun1(void *data)
{
int i;
for(i=0;i<100;i++)
{
pthread_mutex_lock (&locker);
if(ok==false)
pthread_cond_wait(&cond, &locker);
cout << "2";
pthread_mutex_unlock(&locker);
}
}
更新:
您有一场比赛,其中func2()发出的信号比fun1()消耗的信号更快。如果要交替输出“ 1”和“ 2”,则需要双向反馈。