一、(LINUX 线程同步) 引入

点击(此处)折叠或打开

1. {
   
2. int b = 0;
   
3. b = a;
   
4. a = b+1;
   
5. return *this;
   
6. }

点击(此处)折叠或打开

1. //原子操作 加锁
   
2. pthread_mutex_lock(&mtx);
   
3. ++test;
   
4. pthread_mutex_unlock(&mtx);
   
5. //原子操作 解锁
   
6. cout<<pthread_self() <<":";
   
7. test.prit()

点击(此处)折叠或打开

1. /*************************************************************************
   
2. > File Name: error.cpp
   
3. > Author: gaopeng QQ:22389860 all right reserved
   
4. > Mail: gaopp_200217@163.com
   
5. > Created Time: Mon 15 May 2017 12:01:33 AM CST
   
6. ************************************************************************/
   
7. 
   
8. #include<iostream>
   
9. #include <pthread.h>
   
10. #include <string.h>
    
11. #define MAXOUT 1000000
    
12. using namespace std;
    
13. 
    
14. static pthread_mutex_t mtx=PTHREAD_MUTEX_INITIALIZER;
    
15. 
    
16. 
    
17. class testc
    
18. {
    
19. private:
    
20. int a;
    
21. public:
    
22. testc()
    
23. {
    
24. a = 1;
    
25. }
    
26. testc& operator++()
    
27. {
    
28. int b = 0;
    
29. b = a;
    
30. a = b+1;
    
31. return *this;
    
32. 
    
33. }
    
34. void prit()
    
35. {
    
36. cout<<a<<endl;
    
37. }
    
38. };
    
39. 
    
40. 
    
41. testc test = test;
    
42. 
    
43. 
    
44. void* testp(void* arg)
    
45. {
    
46. int i = MAXOUT;
    
47. 
    
48. while(i--)
    
49. {
    
50. //原子操作 加锁
    
51. pthread_mutex_lock(&mtx);
    
52. ++test;
    
53. pthread_mutex_unlock(&mtx);
    
54. //原子操作 解锁
    
55. cout<<pthread_self() <<":";
    
56. test.prit();
    
57. }
    
58. }
    
59. 
    
60. 
    
61. 
    
62. 
    
63. int main(void)
    
64. {
    
65. pthread_t tid[3];
    
66. int er;
    
67. int i = 0;
    
68. 
    
69. while(i<3)
    
70. {
    
71. 
    
72. if ((er = pthread_create(tid+i,NULL,testp,NULL) )!=0 )
    
73. {
    
74. strerror(er);
    
75. return -1;
    
76. }
    
77. i++;
    
78. }
    
79. 
    
80. i = 0;
    
81. 
    
82. while(i<3)
    
83. {
    
84. pthread_join(*(tid+i),NULL);
    
85. i++;
    
86. }
    
87. cout<<"last numer: ";
    
88. test.prit();
    
89. }