POSIX无名信号量死锁问题

osmanthusgfy

自己练习写了一个POSIX无名信号量的demo,
创建了两个线程,一个线程对buf实行写操作,
一个线程对buf实行读操作,利用POSIX无名信号量对临界区进行保护,
但是在一个线程进行读操作时,发生信号量死锁.以下是代码:

1. 
   
2. #include <errno.h>
   
3. #include <pthread.h>
   
4. #include <semaphore.h>
   
5. #include <signal.h>
   
6. #include <stdio.h>
   
7. #include <string.h>
   
8. #include <unistd.h>
   
9. 
   
10. #define BUF_SIZE 256
    
11. 
    
12. static sem_t g_sem;
    
13. static pthread_once_t g_once = PTHREAD_ONCE_INIT;
    
14. 
    
15. static char g_buf[BUF_SIZE];
    
16. 
    
17. void init_once()
    
18. {
    
19.         int err;
    
20. 
    
21.         if( -1 == ( err = sem_init( &g_sem, 0, 1 ) ) )
    
22.         {
    
23.                 fprintf( stderr, "sem_init error:%s\n", strerror( err ) );
    
24. 
    
25.                 return;
    
26.         }
    
27. }
    
28. 
    
29. int read_buf( char* a_buf, const size_t a_size )
    
30. {
    
31.         int err;
    
32. 
    
33.         while( ( -1 == sem_wait( &g_sem ) ) && ( EINTR == errno ) );
    
34. 
    
35.         if( EINTR != errno )
    
36.         {
    
37.                 return -1;
    
38.         }
    
39. 
    
40.         strncpy( a_buf, g_buf, a_size );
    
41.        
    
42.         return sem_post( &g_sem );
    
43. }
    
44. 
    
45. int write_buf( const char* a_buf, const size_t a_size )
    
46. {
    
47.         while( ( -1 == sem_wait( &g_sem ) ) && ( EINTR == errno ) );
    
48. 
    
49.         if( EINTR != errno )
    
50.         {
    
51.                 return -1;
    
52.         }
    
53. 
    
54.         strncpy( g_buf, a_buf, a_size );
    
55.        
    
56.         return sem_post( &g_sem );
    
57. }
    
58. 
    
59. void* run1( void* arg )
    
60. {
    
61.         const char k_data_buf[] = "Nothing is impossible!\n";
    
62. 
    
63.         write_buf( k_data_buf, sizeof( k_data_buf ) );
    
64. 
    
65.         fprintf( stderr, "Written data ok!\n"  );
    
66. 
    
67.         return NULL;
    
68. }
    
69. 
    
70. void start_thd1()
    
71. {
    
72.         pthread_t thd;
    
73.        
    
74.         pthread_create( &thd, NULL, run1, NULL );
    
75. 
    
76.         pthread_join( thd, NULL );
    
77. }
    
78. 
    
79. 
    
80. void* run2( void* arg )
    
81. {
    
82.         char k_data_buf[BUF_SIZE];
    
83.         k_data_buf[BUF_SIZE-1] = '\0';
    
84.        
    
85.        
    
86.         fprintf( stderr, "----------run2--------\n" );
    
87. 
    
88.         read_buf( k_data_buf, sizeof( k_data_buf ) );
    
89. 
    
90.         fprintf( stderr, "%s\n", k_data_buf );
    
91. 
    
92.         return NULL;
    
93. }
    
94. 
    
95. void start_thd2()
    
96. {
    
97.         pthread_t thd;
    
98.        
    
99. 
    
100.         pthread_create( &thd, NULL, run2, NULL );
     
101. 
     
102.         pthread_join( thd, NULL );
     
103. }
     
104. 
     
105. int main( int argc, char** argv )
     
106. {
     
107.         pthread_once( &g_once, init_once );
     
108. 
     
109.         start_thd1();
     
110. 
     
111.         start_thd2();
     
112.        
     
113.         return 0;
     
114. }
     

复制代码

第二个线程调用read_buf时,死在:
while( ( -1 == sem_wait( &g_sem ) ) && ( EINTR == errno ) );
我感觉不是死循环,而是调用sem_wait导致死锁.
程序运行的结果是:
第一个线程的写操作能执行,第二个线程挂了

不知道是什么原因,请高手指教,谢谢!!!!!!!!!!!!!

cwinux_1

下面的这个条件错误。
【        if( EINTR != errno )
        {
                return -1;
        }
】
在此条件下，在没有中断的正常情况下，都返回-1了。
造成信号量没有释放。

osmanthusgfy

没人研究过这方面的东东?

syncpk99

3楼正解啊！！

osmanthusgfy

原帖由 c/unix 于 2009-11-5 14:44 发表


3楼指明了你程序的read_buf里为什么会组塞。

跟你说下怎么改吧
if( EINTR != errno )
{
    return -1;
}
用法根本就是错误的。

因为的sem_wait已经返回成功了也就是返回值是0。
但是你的这个i ...

c/unix大哥,感谢你更进一步指正错误,非常感谢!!!!!!!!!!!!!!!!!!1
我的修改:
  while( ( -1 == sem_wait( &g_sem ) ) && ( EINTR == errno ) );
   if( 0 != errno )
        {
                 sem_post( &g_sem );

                return -1;
        }

还像问问:errno的值为0时对应宏是什么?