2017-05-18 51 views
0

更新包含的代码C:输出前multithreading-父线程退出

第一块我是新来的多线程和我有输出各个线程的结果在C程序的问题之后。具体来说,我试图将一个整数数组中的平均值,最大值和最小值输出给用户,每个用户使用不同的线程。但是,应该打印三个值的父线程在其子线程完成时终止。

为了测试起见,我当前在子线程中打印结果,但我需要在父线程中打印这些值。代码如下:

#include <stdio.h> 
#include <stdlib.h> 
#include <pthread.h> 
#include <unistd.h> 


void *avgThread(int *nums,int*out) 
{ 
    //sleep(1); 
    int total = 0,x,avg; 
    for(x=0;x<7;x++) total+=nums[x]; 
    avg = total/7; 
    *out = avg; 
    printf("%d\n",avg); 
} 

void *minThread(int *nums,int*out) 
{ 
    int min = nums[0],x; 
    for(x=1;x<7;x++) if(nums[x]<min) min=nums[x]; 
    *out = min; 
    printf("%d\n",min); 

} 

void *maxThread(int *nums,int*out) 
{ 
    int max = nums[0],x; 
    for(x=1;x<7;x++) if(nums[x]>max) max=nums[x]; 
    *out = max; 
    printf("%d\n",max); 

} 

void *parentThread(int*nums) 
{ 
    int average,minimum,maximum; 
    pthread_t avg,min,max; 
    pthread_attr_t avgfun,minfun,maxfun; 

    pthread_attr_init(&avgfun); 
    pthread_attr_init(&minfun); 
    pthread_attr_init(&maxfun); 

    pthread_create(&avg, &avgfun, avgThread(nums,&average), NULL); 
    pthread_create(&min, &minfun, minThread(nums,&minimum), NULL); 
    pthread_create(&max, &maxfun, maxThread(nums,&maximum), NULL); 

    pthread_join(avg, NULL); 
    pthread_join(min, NULL); 
    pthread_join(max, NULL); 

    printf("%d\n",maximum); 
    printf("%d\n",average); 
    printf("%d\n",minimum); 
    pthread_join(pthread_self(),NULL); 

    return NULL; 
} 

int main() 
{ 
    int nums[] = {90, 81, 78, 95, 79, 72, 85}; 
    pthread_t prnt; 
    pthread_attr_t parent; 
    pthread_attr_init(&parent); 
    pthread_create(&prnt,&parent,parentThread(nums),NULL); 
    pthread_join(prnt,NULL); 
    sleep(3); 

    exit(0); 
} 

更新

谢谢帕维尔和其他人指出一些事情我做错了。我已经对线程初始化和调用进行了必要的修改。我也能够在父线程中输出计算的平均值,最大值和最小值,但只能通过使所述变量在范围内为全局。如果有人可以告诉我,如果我可以保留:

int average,maximum,minimum 

inside * parentThread并仍然计算它们内部的子线程,这将是伟大的。这里是我现在的代码:

#include <stdio.h> 
#include <stdlib.h> 
#include <pthread.h> 
#include <unistd.h> 

int average,minimum,maximum; 

void *avgThread(void *numsptr) 
{ 
    sleep(1); 
    int *nums=(int*)numsptr; 

    int total = 0,x; 
    for(x=0;x<7;x++) total+=(int)nums[x]; 
    average = total/7; 
    return NULL; 
} 

void *minThread(void *numsptr) 
{ 
    sleep(2); 
    int *nums=(int*)numsptr,x; 
    minimum = nums[0]; 
    for(x=1;x<7;x++) if((int)nums[x]<minimum) minimum=(int)nums[x]; 
    return NULL; 
} 

void *maxThread(void *numsptr) 
{ 
    sleep(3); 
    int *nums=(int*)numsptr,x; 

    maximum = nums[0]; 
    for(x=1;x<7;x++) if((int)nums[x]>maximum) maximum=(int)nums[x]; 
    return NULL; 
} 

void *parentThread(void *numsptr){ 
    int *nums=(int*)numsptr; 
    //int average,minimum,maximum; 
    pthread_t avg,min,max; 
    pthread_attr_t avgfun,minfun,maxfun; 

    pthread_attr_init(&avgfun); 
    pthread_attr_init(&minfun); 
    pthread_attr_init(&maxfun); 

    pthread_create(&avg, &avgfun, &avgThread,(void*)nums); 
    pthread_create(&min, &minfun, &minThread,(void*)nums); 
    pthread_create(&max, &maxfun, &maxThread,(void*)nums); 

    pthread_join(avg, NULL); 
    printf("The average value is %d\n",average); 
    pthread_join(min, NULL); 
    printf("The minimum value is %d\n",minimum); 
    pthread_join(max, NULL); 
    printf("The max value is %d\n",maximum); 

    return NULL; 
} 

int main() 
{ 
    int nums[] = {90, 81, 78, 95, 79, 72, 85}; 
    pthread_t prnt; 
    pthread_attr_t parent; 
    pthread_attr_init(&parent); 
    pthread_create(&prnt,&parent,&parentThread,(void*)nums); 
    pthread_join(prnt,NULL); 

    exit(0); 
} 
+0

关于'在pthread_join(pthread_self(),NULL);',阻塞自己的线程,直到它完成似乎并不像一个好的战术决定。坦率地说,我不知道会发生什么。我希望得到一个错误消息,但我不会因为锁定而感到惊讶。 – user4581301

+0

'pthread_create(&prnt,&parent,parentThread(nums),NULL);'以及对'pthread_create()'的其他调用表明您对如何将函数指针和参数传递给线程有严重的误解。它应该是'pthread_create(&prnt,&parent,parentThread,nums)'。对于其他的你需要创建一个'struct',因为你只能传递一个指针作为参数。 –

+0

你的线程函数不返回承诺的'void *'。这是[Undefined Behavior。](http://en.cppreference.com/w/cpp/language/ub)。很难预测该计划将做什么。 – user4581301

回答

2

您不能正确启动线程。你必须通过功能,将执行,但你实际上是调用你的函数和返回值传递给pthread_create

// call parentThread(nums) and then create thread. 
pthread_create(&prnt, &parent, parentThread(nums),NULL); 

你想要做的是这样的:

void *parentThread(void *nums_ptr) 
{ 
    int *nums = (int*)nums_ptr; 
    ... 
    return NULL; 
} 

int main() 
{ 
    int nums[] = {90, 81, 78, 95, 79, 72, 85}; 
    pthread_t prnt; 
    pthread_create(&prnt, NULL, &parentThread, (void*)nums); 
    ... 
} 

同样适用于所有你的其他线程。 其他问题你有:

  • 你的线程函数(即pthreads期望)应该采取一个空指针并返回void指针。例如:void *threadFunc(void *nums)
  • 你的函数返回的东西(如return NULL;
  • 你不应该试图联合自己的线程:pthread_join(pthread_self(),NULL);

如果有人能告诉我,如果我能保持:int average,maximum,minimum inside * parentThread并且仍然在子线程内计算它们

当然你可以做到这一点。定义一些struct,用于存储所有这些数据,并通过指针指向的数据到你的主题:

struct myState 
{ 
    int average, minimum, maximum; 
    int *nums 
}; 

void *avgThread(void *data) 
{ 
    sleep(1); 
    myState *state = (myState*)data; 

    int total = 0,x; 
    for(int x=0; x<7; x++) 
     total += state->nums[x]; 
    state->average = total/7; 
    return NULL; 
} 

void *parentThread(void *nums_ptr) 
{ 
    int *nums = (int*)nums_ptr; 
    myState state; 
    state.nums = nums; 
    ... 
    pthread_create(&avg, &avgfun, &avgThread, &state); 
    ... 
    pthread_join(avg, NULL); 
    printf("The average value is %d\n", state.average); 
    ... 
    return NULL; 
}