我正在尝试实现这个简单的示例,说明如何使用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”,则需要双向反馈。

09-04 07:21