更新包含的代码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);
}
关于'在pthread_join(pthread_self(),NULL);',阻塞自己的线程,直到它完成似乎并不像一个好的战术决定。坦率地说,我不知道会发生什么。我希望得到一个错误消息,但我不会因为锁定而感到惊讶。 – user4581301
'pthread_create(&prnt,&parent,parentThread(nums),NULL);'以及对'pthread_create()'的其他调用表明您对如何将函数指针和参数传递给线程有严重的误解。它应该是'pthread_create(&prnt,&parent,parentThread,nums)'。对于其他的你需要创建一个'struct',因为你只能传递一个指针作为参数。 –
你的线程函数不返回承诺的'void *'。这是[Undefined Behavior。](http://en.cppreference.com/w/cpp/language/ub)。很难预测该计划将做什么。 – user4581301