Chinaunix

标题: 才学多线程读写锁，这个写线程为何一直取不到锁？ [打印本页]

---

作者: qfmeal    时间: 2016-02-04 14:34
标题: 才学多线程读写锁，这个写线程为何一直取不到锁？
才学习多线程读写锁。
参照网上的教程，自己写了简单的例子，但是写线程一直都未进入，高手帮忙看一下我哪里错了，谢谢！

1. #include <stdio.h>
   
2. #include <pthread.h>
   
3. #include <unistd.h>
   
4. #include <iostream>
   
5. 
   
6. using namespace std;
   
7. 
   
8. 
   
9. int g_count = 0;
   
10. pthread_rwlock_t rwlock;
    
11. 
    
12. void * thd_func_read_1(void * arg)
    
13. {
    
14.     while(1)
    
15.     {
    
16.         pthread_rwlock_rdlock(&rwlock);
    
17.         sleep(1);
    
18.         cout<<"read1 count:"<<g_count<<endl;
    
19.         pthread_rwlock_unlock(&rwlock);
    
20.     }
    
21.     return NULL;
    
22. }
    
23. 
    
24. void * thd_func_read_2(void * arg)
    
25. {
    
26.     while(1)
    
27.     {
    
28.         pthread_rwlock_rdlock(&rwlock);
    
29.         sleep(1);
    
30.         cout<<"read2 count:"<<g_count<<endl;
    
31.         pthread_rwlock_unlock(&rwlock);
    
32.     }
    
33.     return NULL;
    
34. }
    
35. 
    
36. void * thd_func_write(void * arg)
    
37. {
    
38.     while(1)
    
39.     {
    
40.         pthread_rwlock_wrlock(&rwlock);
    
41.         sleep(1);
    
42.         cout<<"write count:"<<++g_count<<endl;
    
43.         if( g_count >= 5 )
    
44.         {
    
45.             pthread_rwlock_unlock(&rwlock);
    
46.             pthread_exit(0);
    
47.             return NULL;
    
48.         }
    
49.         pthread_rwlock_unlock(&rwlock);
    
50.     }
    
51.     return NULL;
    
52. }
    
53. 
    
54. int main(int argc, char **argv)
    
55. {
    
56.     int ret;
    
57.     pthread_t thd_read_1, thd_read_2, thd_write;
    
58.     pthread_rwlock_init(&rwlock, NULL);
    
59. 
    
60.     ret = pthread_create(&thd_read_1, NULL, thd_func_read_1, NULL); //创建线程1
    
61.     if(ret){
    
62.         perror("thd_read_1:\n");
    
63.         return 1;
    
64.     }
    
65. 
    
66.     ret = pthread_create(&thd_read_2, NULL, thd_func_read_2, NULL); //创建线程2
    
67.     if(ret){
    
68.         perror("thd_read_2: \n");
    
69.         return 1;
    
70.     }
    
71. 
    
72.     ret = pthread_create(&thd_write, NULL, thd_func_write, NULL); //创建线程2
    
73.     if(ret){
    
74.         perror("thd_read_3: \n");
    
75.         return 1;
    
76.     }
    
77. 
    
78.     pthread_join(thd_read_1,NULL);
    
79.     pthread_join(thd_read_2,NULL);
    
80.     pthread_join(thd_write,NULL);
    
81. 
    
82.     return 0;
    
83. }
    

复制代码

输出的内容也很奇怪：
read2 count:read1 count:00

read1 count:read2 count:00

read1 count:read2 count:00

read1 count:0
read2 count:0
read2 count:0
read1 count:0
read1 count:read2 count:00

read1 count:read2 count:00

read1 count:0
read2 count:0
read2 count:read1 count:00

---

作者: hanzhenlll    时间: 2016-02-04 15:15
适当的增加一些延迟 比如usleep(20) 之类。


  过度的快速循环使用锁 本身就是一种不健康的设计。

---

作者: qfmeal    时间: 2016-02-05 15:28
我已经加了sleep(20)。   但是还跟原来一样。


其实我不让读线程1,2,处在循环中，程序运行就正常了。  就是不知道为什么。

---

作者: hellioncu    时间: 2016-02-05 15:39
读线程占用锁太频繁，你在加锁之后再sleep，写线程更难抢到锁了，放在读解锁之后才对。

另外读写锁可以设置写优先。

---

作者: lxyscls    时间: 2016-02-15 14:47


回复 1# qfmeal

    [root@router ~]# ./test
read1 count:read2 count:00

write count:1
write count:2
write count:3
write count:4
write count:5
read1 count:read2 count:5
5
read1 count:5
read2 count:5

1.     pthread_rwlockattr_t attr;
   
2.     pthread_rwlockattr_init(&attr);
   
3.     pthread_rwlockattr_setkind_np(&attr, 2);
   
4.     pthread_rwlock_init(&rwlock, &attr);

复制代码

设置“写优先”

---

欢迎光临 Chinaunix (http://bbs.chinaunix.net/)

Powered by Discuz! X3.2