信号量同步两个线程的问题，求指导[已解决]

fightingM

求教的问题描述：
两个线程，
想实现的步骤如下,read_thread线程工作16次后send_thread线程才工作，
但是调试结果显示只能执行一次read_thread，打印一次read_thread running程序就停止了，
请教各位，程序是哪里问题？

【fix】 两个线程之间同步，一个信号量就可以了

1. #include <stdio.h>
   
2. #include <stdlib.h>
   
3. #include <string.h>
   
4. #include <errno.h>
   
5. #include <pthread.h>
   
6. #include <semaphore.h>
   
7. sem_t rd_sem,net_sem;
   
8. int count=0;
   
9. 
   
10. void* read_thread(void* arg)
    
11. {
    
12.    int rd_ret=0;
    
13.    int i=0;
    
14.         while(1)
    
15.         {
    
16.        
    
17.          count+=1;
    
18.           printf("read_thead running!\n");
    
19.           if(count==16)
    
20.                 {
    
21.                     count=0;
    
22.                    sem_post(&net_sem);
    
23.                 }
    
24. 
    
25.         sleep(2);       
    
26.         }
    
27. 
    
28.        
    
29. }
    
30. 
    
31. void* send_thread(void* arg)
    
32. {
    
33.       while(1)
    
34.         {
    
35.            sem_wait(&net_sem);
    
36.            printf("Send dates to PC\n");
    
37.         }
    
38. }
    
39. 
    
40. int main()
    
41. {
    
42.         int ret=0;
    
43.         pthread_t  pid1,pid2;
    
44.         [u]ret=sem_init(&rd_sem,0,1);//保证先启动读线程   
    
45. [/u]          ret=sem_init(&net_sem,0,0);
    
46.              if(ret!=0)
    
47.                 {
    
48.                     perror("sem_init");
    
49.                 }
    
50.              ret = pthread_create(&pid1, NULL,read_thread, NULL);
    
51.                 if(ret!=0)
    
52.                 {
    
53.                     perror("read_thread");
    
54.                 }
    
55.               ret = pthread_create(&pid2, NULL,send_thread, NULL);
    
56.                 if(ret!=0)
    
57.                 {
    
58.                     perror("send_thread");
    
59.                 }
    
60.   pthread_join(pid2,NULL);
    
61.         return 0;
    
62. 
    
63. }
    

复制代码

chenyuman510

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <errno.h>
#include <pthread.h>
#include <semaphore.h>
sem_t rd_sem,net_sem;
int count=0;

void* read_thread(void* arg)
{
   sem_wait(&rd_sem);
   int rd_ret=0;
   int i=0;
        while(1)
        {
          //sem_wait(&rd_sem);
         count+=1;
          printf("read_thead running!\n");
          if(count==16)
                {
                    count=0;
                   sem_post(&net_sem);
                }

        sleep(2);        
        }

        
}

void* send_thread(void* arg)
{
      while(1)
        {
           sem_wait(&net_sem);
           printf("Send dates to PC\n");
           sem_post(&rd_sem);
        }
}

int main()
{
        int ret=0;
        pthread_t  pid1,pid2;
         ret=sem_init(&rd_sem,0,1);//保证先启动读线程
          ret=sem_init(&net_sem,0,0);
             if(ret!=0)
                {
                    perror("sem_init");
                }
             ret = pthread_create(&pid1, NULL,read_thread, NULL);
                if(ret!=0)
                {
                    perror("read_thread");
                }
              ret = pthread_create(&pid2, NULL,send_thread, NULL);
                if(ret!=0)
                {
                    perror("send_thread");
                }
  pthread_join(pid2,NULL);
        return 0;

}

core1011

你这帖子貌似在csdn发过啊，我给你回帖了，你去csdn看一下就可以了！

fightingM

回复 3# core1011
是的 谢谢了 已经解决了


   

crazyhadoop

回复 4# fightingM


    把解决方法贴到你这个问题下多好~