嵌入式Linux应用程序开发——多线程2(线程的同步——互斥锁)

2019-07-13 05:07发布

/*pthread2.c*/ #include #include
#include
#include
int global;
pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;//静态初始化互斥锁
void *thread_function(void *arg)
{
    int i,j;
    for(i=0;i<10;i++)
    {
      pthread_mutex_lock(&mutex);//上锁
      j = global;
      j++;
      printf("-");
      fflush(stdout);
      global = j;
      usleep(10000);
      pthread_mutex_unlock(&mutex);//解锁
    }
    return NULL;
}
int main(void)
{
    pthread_t th_new;
    int i;
    setbuf(stdout,NULL);
    if(pthread_create(&th_new,NULL,thread_function,NULL))
    {
      perror("error creating thread.");
      abort();
    }
    for(i=0;i<10;i++)
    {
      pthread_mutex_lock(&mutex);
      global++;
      pthread_mutex_unlock(&mutex);
      printf("m");
      fflush(stdout);
      usleep(10000);
    }
    if(pthread_join(th_new,NULL))
    {
      perror("error joining thread");
      abort();
    }
    printf(" result is :%d ",global);
    exit(0);
}