0

这是我拥有的代码，它使用 g++ 编译和运行，但出现分段错误。我知道它发生在 pthread_join 语句周围，但我不知道为什么。

#include <iostream>
#include <stdio.h>
#include <fstream>
#include <pthread.h>
#include <stdlib.h>
#include <sstream>

using namespace std;

struct data{
    string filename;
    int x;
    int y;
};

void *threadFunction(void *input){
    data *file = (data *) input;
    string filename = file->filename;
    ifstream myFile;
    int xCount = 0;
    int yCount = 0;
    myFile.open(filename.c_str());
    string line;
    while(myFile >> line){
        if(line == "X"){
            xCount++;
        }else if(line == "Y"){
            yCount++;
        }
    }
    file->x = xCount;
    file->y = yCount;
    return (void *) file;
}

int main(){
    pthread_t myThreads[20];
    data *myData = new data[20];

    for(int i = 0; i < 20; i++){
        ostringstream names;
        names << "/filepath/input" << i+1 << ".txt";
        myData[i].filename = names.str();
        myData[i].x = 0;
        myData[i].y = 0;
    }
    for(int i = 0; i < 20; i++){
        int check = pthread_create(&myThreads[i], NULL, threadFunction, (void *) &myData[i]);
        if(check != 0){
            cout << "Error Creating Thread\n";
            exit(-1);
        }
    }



    int xCount = 0;
    int yCount = 0;

    for(int i = 0; i < 20; i++){
        data* returnedItem;
        pthread_join(myThreads[i], (void**) returnedItem);
        xCount += returnedItem->x;
        yCount += returnedItem->y;
    }

    cout << "Total X: " << xCount << "\n";
    cout << "Total Y: " << yCount << "\n";

}

我没有从我的 threadFunction 正确调用 return 吗？我一直在尝试很多不同的事情，但我仍然不知道发生了什么......任何帮助将不胜感激！（我打开的文本文件每行包含一个 X 或 Y。我的目标是计算 20 个文本文件中 X 和 Y 的总数）

4

3 回答 3

0 
pthread_join(myThreads[i], (void**) returnedItem);

应该

pthread_join(myThreads[i], (void**) &returnedItem);

您要求 join 将 的值设置为您的线程函数返回的returnedItem任何值......void*所以您需要提供.returnedItem

于 2012-10-21T23:09:02.423 回答
0

to 的第二个参数pthread_join()是void**将结果存储到其中的 a。但是，您正在传递一个随机值。这应该看起来像这样：

void* result;
pthread_join(myThread[i], &result);
data* returnedItem = static_cast<data*>(result);

当然，这假设 adata*确实返回了。

于 2012-10-21T23:09:26.890 回答
0

的第二个参数pthread_join将用于返回，返回线程的值，所以在里面的某个地方pthread_join我们有一个调用的代码*secondArgument = thread_return_value，但让我们看看你在这里做什么：

// You are not initializing returnedItem, so it contain some garbage value
// For example 0x12345678
data* returnedItem;
// Now you cast that garbage to (void**), and pthread_join will call
// *(0x12345678) = thread_return_value that will cause segmentation fault
pthread_join(myThreads[i], (void**) returnedItem);

但是您希望将返回值复制到returnedItem，对吗？如果您的回答是肯定的，您应该传递 to 的地址，returnedItem以便pthread_join它可以将其复制到那里。因此，将您的电话更改为：

pthread_join(myThreads[i], (void**) &returnedItem);
于 2012-10-21T23:12:25.100 回答