1

我正在研究互斥体，但我陷入了练习中。对于给定目录中的每个文件，我必须创建一个线程来读取它并显示其内容（如果顺序不正确，没问题）。

到目前为止，线程正在运行这个函数：

void * reader_thread (void * arg)
{   

    char * file_path = (char*)arg;
    FILE * f;
    char temp[20];
    int value;

    f=fopen(file_path, "r");
    printf("Opened %s.\n",file_path);

    while (fscanf(f, "%s",temp)!=EOF)
        if (!get_number (temp, &value)) /*Gets int value from given string (if numeric)*/
             printf("Thread %lu -> %s: %d\n", pthread_self(), file_path, value );

    fclose(f);
    pthread_exit(NULL);

}

由接收指针的函数调用，该DIR指针先前由opendir(). （我在这里省略了一些错误检查以使其更清晰，但我完全没有错误。）

int readfiles (DIR * dir, char * path)
{

    struct dirent * temp = NULL;        
    char  * file_path;
    pthread_t thList [MAX_THREADS];
    int nThreads=0, i;

    memset(thList, 0, sizeof(pthread_t)*MAX_THREADS);
    file_path=malloc((257+strlen(path))*sizeof(char));      

    while((temp = readdir (dir))!=NULL && nThreads<MAX_THREADS) /*Reads files from dir*/
    {

        if (temp->d_name[0] != '.')                     /*Ignores the ones beggining with '.'*/
        {   
            get_file_path(path, temp->d_name, file_path);   /*Computes rute (overwritten every iteration)*/
            printf("Got %s.\n", file_path);
            pthread_create(&thList[nThreads], NULL, reader_thread, (void * )file_path)  

            nThreads++; 
        }       
    }

    printf("readdir: %s\n", strerror (errno ));     /*Just in case*/

    for (i=0; i<nThreads ; i++)
        pthread_join(thList[i], NULL)

    if (file_path)
        free(file_path);

    return 0;

}

我的问题是，虽然路径计算得很好，但线程似乎没有收到正确的参数。他们都读取同一个文件。这是我得到的输出：

Got test/testB.
Got test/testA.
readdir: Success
Opened test/testA.
Thread 139976911939328 -> test/testA: 3536
Thread 139976911939328 -> test/testA: 37
Thread 139976911939328 -> test/testA: -38
Thread 139976911939328 -> test/testA: -985
Opened test/testA.
Thread 139976903546624 -> test/testA: 3536
Thread 139976903546624 -> test/testA: 37
Thread 139976903546624 -> test/testA: -38
Thread 139976903546624 -> test/testA: -985

如果我在下一个线程开始之前加入线程，它可以正常工作。所以我假设某处有一个关键部分，但我真的不知道如何找到它。我试过互斥整个线程函数：

void * reader_thread (void * arg)
{   

    pthread_mutex_lock(&mutex_file);
    /*...*/
    pthread_mutex_unlock(&mutex_file);

}

此外，在第二个函数中对 while 循环进行互斥。甚至两者同时。但它不会以任何方式工作。顺便说一句， mutex_file 是一个全局变量，由pthread_mutex_init()in初始化main()。

我真的很感谢你的建议，因为我真的不知道我做错了什么。我也希望有一些好的参考资料或书籍，因为互斥锁和 System V 信号量对我来说有点困难。

非常感谢你。

4

2 回答 2

3

好吧，您将与文件路径完全相同的指针传递给两个线程。结果，他们从同一个字符串中读取文件名并最终读取同一个文件。实际上，你在这里有点幸运，因为实际上你有一个竞争条件——你更新字符串指针的内容，file_path同时启动从该指针读取的线程，所以你最终可能会有一个线程在它读取该内存时正在改变。您需要做的是分别为每个线程分配一个参数（即循环malloc中的调用和相关逻辑while），然后在线程退出后释放这些参数。

于 2012-11-09T20:53:48.270 回答
3

看起来您正在为所有线程使用相同的 file_path 缓冲区，只是用下一个名称一遍又一遍地加载它。您需要为每个线程分配一个新字符串，并让每个线程在使用后删除该字符串。

编辑

由于您已经有一个线程数组，您可以只创建一个 char[] 的并行数组，每个数组都保存相应线程的文件名。这将避免 malloc/free。

于 2012-11-09T20:54:56.463 回答