linux多线程—互斥量

1071阅读　0评论2011-12-08　啦哆A梦
分类：

多个线程对同一变量读写，如果不做同步处理，数据可能不一致

  1. #include <stdio.h>
  2. #include <pthread.h>
  3. #include <time.h>
  4. static int count=0;
  5. void *test1()
  6. {
  7.     printf("pthread 1\n");
  8.     int i=0;
  9.     while(i++!=11111110) //如果数据太小在线程让出cpu之前就已经完成操作，就看不到不一致的效果鸟～～
  10.     {
  11.         count++;
  12.         }
  13.     return NULL;
  14. }

  16. void *test2()
  17. {
  18.     printf("pthread 2\n");
  19.     int i=0;
  20.     while(i++!=11111160)
  21.     {
  22.         count++;
  23.         }
  24.     return NULL;
  25. }

  27. int main()
  28. {
  29.     pthread_t a,b;
  30.     pthread_create(&a,NULL,test1,NULL); //创建新线程，默认线程属性
  31.     pthread_create(&b,NULL,test2,NULL);
  32.     sleep(2);
  33.     printf("%d\n",count);
  34. }
运行结果：
  1. coder@coder:~/C and C++/pthread$ ./a.out
  2. pthread 1
  3. pthread 2
  4. 14280152
  5. coder@coder:~/C and C++/pthread$ ./a.out
  6. pthread 1
  7. pthread 2
  8. 15333212
  9. coder@coder:~/C and C++/pthread$ ./a.out
  10. pthread 1
  11. pthread 2
  12. 13588147
使用互斥量保证只有一个线程在读写变量，在它完成工作之前，其他线程只能等待
  1. #include <stdio.h>
  2. #include <pthread.h>
  3. #include <time.h>
  4. static int count=0;
  5. pthread_mutex_t p_lock;                            //定义互斥量
  6. void *test1()
  7. {
  8.     pthread_mutex_lock(&p_lock); //加锁 ，如果被其他线程抢先一步，就阻塞等待
  9.     printf("pthread 1\n");
  10.     int i=0;
  11.     while(i++ != 11111110)
  12.     {
  13.         count++;
  14.     }
  15.     pthread_mutex_unlock(&p_lock); //解锁
  16.     return NULL;
  17. }

  19. void *test2()
  20. {
  21.     pthread_mutex_lock(&p_lock);
  22.     printf("pthread 2\n");
  23.     int i=0;
  24.     while(i++ != 11111160)
  25.     {
  26.         count++;
  27.     }
  28.     pthread_mutex_unlock(&p_lock);
  29.     return NULL;
  30. }

  32. int main()
  33. {
  34.     pthread_t a,b;
  35.     pthread_mutex_init(&p_lock,NULL);                //使用默认属性初始化互斥量
  36.     if(pthread_create(&a,NULL,test1,NULL)!=0) //创建新线程，默认线程属性
  37.     {
  38.         printf("can‘t create thread\n");
  39.     }
  40.     if(pthread_create(&b,NULL,test2,NULL)!=0)
  41.     {
  42.         printf("can‘t create thread\n");
  43.     }
  44.     pthread_mutex_destroy(&p_lock);                  //销毁
  45.     sleep(2);
  46.     printf("%d\n",count);
  47.     }
运行结果：
  1. coder@coder:~/C and C++/pthread$ ./a.out
  2. pthread 1
  3. pthread 2
  4. 22222270
  5. coder@coder:~/C and C++/pthread$ ./a.out
  6. pthread 1
  7. pthread 2
  8. 22222270
  9. coder@coder:~/C and C++/pthread$ ./a.out
  10. pthread 1
  11. pthread 2
  12. 22222270

gcc pthread.c -lphtread

上一篇：基于mini2440的linphone移植
下一篇：项目进度计划的一些问题