我在多线程中遇到了一些问题

Question

我正在为这个代码苦苦挣扎。这是关于从文本文件中计算一些模式。我试图使用线程（除法和征服）处理，但它返回了一个错误的值。我使用互斥量值来同步临界区。代码如下。第一个主要参数是线程数，第二个是我希望从中计数模式的文本文件的名称，以及我希望查看文本的以下模式。 请救救我吧..

代码如下

---

char *buffer; 
int fsize, count; 
char **searchword; 
int *wordcount; 
int *strlength; 

typedef struct _params{ 
int num1; 
int num2; 
}params; 

pthread_mutex_t mutex; 

void *childfunc(void *arg) 
{ 

int size, i, j, k, t, start, end, len, flag = -1; 

int result; 

params *a = (params *)arg; 
start = a->num1; 
end = a->num2; 


while(1){ 

if(start == 0 || start == fsize) 
break; 
if(buffer[start]!= ' ' && buffer[start] != '\n' && buffer[start] != '\t') 
start++; 
else 
break; 
} 

while(1){ 

if(end == fsize) 
break; 
if(buffer[end] != ' ' && buffer[end] != '\n' && buffer[end] != '\t') 
end++; 
else 
break; 
} 

for(i = 0; i < count; i++){ 

len = strlength[i]; 
for(j = start; j<(end - len + 1); j++){ 

if(buffer[j] == searchword[i][0]){ 

flag = 0; 
for(k = j +1; k<j + len; k++){ 
if(buffer[k] != searchword[i][k-j]) 
{ 
flag = 1; 
break; 

} 

} 
if(flag == 0){ 

pthread_mutex_lock(&mutex); 
wordcount[i]++; 
pthread_mutex_unlock(&mutex);// mutex unlocking 
sleep(1); 
flag = -1; 

} 
} 

} 

} 

} 

int main(int argc, char **argv){ 

FILE *fp; 
char *inputFile; 
pthread_t *tid; 
int *status; 
int inputNumber, i, j, diff, searchstart, searchend; 
int result = 0; 

count = argc -3; 
inputNumber = atoi(argv[1]); 
inputFile = argv[2]; 

searchword = (char **)malloc(sizeof(char *)*count); 
tid = malloc(sizeof(pthread_t)*inputNumber); 
strlength = (int *)malloc(4*count); 
status = (int *)malloc(4*inputNumber); 
wordcount = (int *)malloc(4*count); 

for(i = 0; i < count; i++) 
searchword[i] = (char*)malloc(sizeof(char)*(strlen(argv[i+3]) + 1)); 
for(i = 3; i < argc; i++) 
strcpy(searchword[i-3], argv[i]); 
fp = fopen(inputFile, "r"); 
fseek(fp, 0, SEEK_END); 
fsize = ftell(fp); 
rewind(fp); 
buffer = (char *)malloc(1*fsize); 

fread(buffer, fsize, 1, fp); 

diff = fsize/inputNumber; 
if(diff == 0) 
diff = 1; 

for(i = 0; i < count ; i++){ 
strlength[i] = strlen(searchword[i]);  
wordcount[i] = 0; 
} 


for(i = 0; i < inputNumber; i++){ 

searchstart = 0 + i*diff; 
searchend = searchstart + diff; 

if(searchstart > fsize) 
searchstart = fsize; 

if(searchend > fsize) 
searchend = fsize; 

if(i == inputNumber -1) 
searchend = fsize; 
params a; 
a.num1 = searchstart; 
a.num2 = searchend; 

pthread_mutex_init(&mutex, NULL); 

result = pthread_create(&tid[i], NULL, childfunc, (void *)&a); 

if(result < 0){ 
perror("pthread_create()"); 
} 

} 

//스레드 받는 부분 

for(i = 0; i < inputNumber; i++){ 
result = pthread_join(tid[i], (void **)status); 

if(result < 0) 
perror("pthread_join()"); 
} 
pthread_mutex_destroy(&mutex); // mutex 해제 
for(i = 0; i < count; i++) 
printf("%s : %d \n", searchword[i], wordcount[i]); 

for(i = 0; i < count; i++) //동적메모리해제 
free(searchword[i]); 
free(searchword); 

free(buffer); 
free(tid); 
free(strlength); 
free(wordcount); 
free(status); 

fclose(fp); 


return 0; 
} 

Answer 1

params a; // new a for each loop, previous a no longer exists 
a.num1 = searchstart; 
a.num2 = searchend; 

pthread_mutex_init(&mutex, NULL); 

result = pthread_create(&tid[i], NULL, childfunc, (void *)&a); 

if(result < 0){ 
perror("pthread_create()"); 
} 

} // a goes out of scope here 

您通过每个线程的a地址，但随后a超出范围在创建线程之后。所以线程现在有堆栈上随机剩余垃圾的地址。

您需要对多个线程访问的任何对象拥有一些所有权的概念，例如a就在这里。它可以由称为pthread_create的线程拥有，由新创建的线程拥有，或共同拥有。但你必须保持一致。你没有这些，为什么？

是a拥有唯一的线程，调用pthread_create？不，因为新创建的线程有一个指向它的指针并通过该指针访问它。所以调用pthread_create的线程不能销毁它。

是a只拥有由pthread_create创建的线程吗？不，因为它位于调用pthread_create的线程栈中，并且在下一个循环出现时将不再存在。

是a共同所有？嗯，不，因为调用pthread_create的线程可以在之前破坏对象，新创建的线程可以访问它。

因此没有多线程使用的理智模型后跟a。它坏了。

这个问题的一个常见解决方案是为每个线程分配一个新结构（使用malloc或new），填充它并将结构的地址传递给线程。线程free（或delete）在完成它的结构。