线程问题 pthread

badeager

1. #include <stdio.h>;
   
2. #include <stdlib.h>;
   
3. #include <pthread.h>;
   
4. #include <time.h>;
   
5. #include <string.h>;
   
6. #include <sys/stat.h>;
   
7. #include <sys/types.h>;
   
8. #include <errno.h>;
   
9. 
   
10. #define BUFFER 512
    
11. #define MAX_HOST        256       
    
12. 
    
13. struct rcmd_type{
    
14.         char *hostname;
    
15.         char *time;
    
16. };
    
17. 
    
18. 
    
19. void *_exec_program(void *arg) {
    
20.         int ret;
    
21.         char *buff;
    
22.         struct rcmd_type *host = (struct rcmd_type *)arg;
    
23.         printf("GET HOSTNAME: %s TIME: %s \n",host->;hostname,host->;time);
    
24.                  ret =1;
    
25.         pthread_exit(&ret);
    
26. }
    
27. 
    
28. 
    
29. int main(int argc,char **argv)
    
30. {
    
31.         pthread_t *thread;
    
32.         char *hostname[MAX_HOST];
    
33.         int i,j,host_num;
    
34.         int ret;
    
35.         struct rcmd_type host;
    
36.        
    
37.         host_num = get_host((char **)(&hostname));
    
38.         if(argc!=2)
    
39.                 return 0;
    
40.        
    
41.         if(host_num<0)
    
42.                 return 0;
    
43.                        
    
44.         if((thread=(pthread_t *)malloc(sizeof(pthread_t)*host_num))==NULL){
    
45.                 fprintf(stderr,"Out Of Memory!\n\a");
    
46.                 exit(1);
    
47.         }
    
48.         host.time = argv[1];
    
49.         for(i=0,j=0;i<=host_num;i++,j++){
    
50.                 host.hostname = NULL;
    
51.                 host.hostname = hostname[i];
    
52.                 if(pthread_create(&thread[j],NULL,_exec_program,(void *)&host)!=0)
    
53.                          fprintf(stderr,"Create Thread[%d] Error:%s\n\a",i,strerror(errno));
    
54.         }
    
55.        
    
56.         ret = 0;
    
57.         for(i=0;i<=host_num;i++){
    
58.                 if(pthread_join(thread[i],(void *)&ret)!=0)
    
59.                          fprintf(stderr,"Thread[%d] Join Error:%s\n\a",i,strerror(errno));
    
60.                 else {
    
61.                            if(ret==0)
    
62.                                    continue;
    
63.                            printf("Thread[%d] Exit\n\a",i);
    
64.                            free(hostname[i]);
    
65.                           
    
66.                 }
    
67.         }
    
68.         free(thread);
    
69.         exit(0);
    
70. }
    
71. 
    
72. 
    
73. 
    

复制代码

请斑竹帮我看看,怎么每次线程得到的参数有问题,或老是一样的或不全!
get_host 程序主要作用是创建服务器的数组,然后返回服务器数目

bjf

1.你要在get_host函数之后检查host_num和hostname的内容。

2.如果host_num大于1，那么前一个线程的参数被后一个线程覆盖是一定的，因为他们的参数都是host这个变量的地址。

3.那个for里面为什么要用i和j两个变量，一个就可以了啊

feishq

你的代码，出错是必然的。

线程是在同一个地址空间里运行的。多个线程共享同一个进程的资源，包括全局变量等。

考虑这种情况：
主线程pthread_create了一个子线程，准备从host变量中取数据，在尚未取之时，主线程获得执行权，而主线程此时处在循环体中，修改了host数据。当子进程再次获得CPU时，host变量已经物是人非了。

这就是最典型的竞态条件，可以通过添加互斥量等来同步（code略）
或者将host改为
struct rcmd_type host[MAX_HOST]

   for(i=0;i<=host_num;i++,j++){
      host.time = argv[1];
      host.hostname = NULL;
      host.hostname = hostname;
      if(pthread_create(&thread,NULL,_exec_program,(void *)&host)!=0)
          fprintf(stderr,"Create Thread[%d] Error:%s\n\a",i,strerror(errno));
  }

badeager

为什么不用host数组就不行呢
我在传送参数是已经给他赋值了,
只是用了一个变量指针,为什么不行了呢

feishq

因为OS调度的缘故，主线程有可能在你的子线程去hostname变量的值之前已经修改了该变量，甚至你取到的有可能是该了一半的值。

建议看看关于线程同步的理论。

深蓝unix

我也遇到这个问题，可是，能不能不用数组实现host的传递呢，因为我的线程数量是未知的，应该有一种方法给线程传递参数吧。。。。