0

我正在尝试解决同步的一个小问题。但是当我加入线程时，我得到了第五次迭代的段错误！如果我只创建 4 个线程就完美了。

在这里，我将代码留下一些关于如何处理线程的基础知识。

#include <stdio.h>              
#include <stdlib.h>             
#include <string.h>             
#include <pthread.h>            
#include <semaphore.h>

sem_t HackersEmploy_Counter;
int hackerOnBoat, employOnBoat, B, b, hackerResagado, employResagado;

sem_t Board;
int onBoatId[4];     
char onBoatType[4]; 

sem_t Bote;  

typedef struct{
    FILE* log;
    int ID;
}param;

void* HackerArrive(void* para){
    param* var = (param*) para;
    printf("Create Hacker %i\n", var->ID-1);
    pthread_exit(0);
}

void* EmployeeArrive(void* para){
    param* var = (param*) para;
    printf("Create Employee %i\n", var->ID-1);
    pthread_exit(0);
}

int main(int argc, char **argv) {
    sem_init(&HackersEmploy_Counter,0,1);
    sem_init(&Bote,0,4);
    sem_init(&Board,0,1);
    FILE* log;
    log = fopen("result_simulacion.txt", "w");
    int E, e=1, H, h=1, i, r;
    hackerOnBoat=0; employOnBoat=0; b=1; hackerResagado=0; employResagado=0;
    for (i=1; i<argc; i++){
        if (strcmp(argv[i],"-h")==0){
            i++;
            H = atoi(argv[i]);
        }
        if (strcmp(argv[i],"-e")==0){
            i++;
            E = atoi(argv[i]);
        }
        if (strcmp(argv[i],"-b")==0){
            i++;
            B = atoi(argv[i]);
        }
    }
    pthread_t* bank = (pthread_t*) malloc( (E+H) * sizeof (pthread_t*));
    param* var = (param*) malloc( (E+H) + sizeof (param*));
    for (i=0; i<H+E; i++){
        r = rand() % 2;
        if (r==0){
            if (h<=H){
                var[i].log = log;
                var[i].ID = h;
                pthread_create(&bank[i], NULL, HackerArrive, (void*) &var[i]);
                h++;
            }else{
                var[i].log = log;
                var[i].ID = e;
                pthread_create(&bank[i], NULL, EmployeeArrive, (void*) &var[i]);
                e++;
            }
        }else{
            if (e<=E){
                var[i].log = log;
                var[i].ID = e;
                pthread_create(&bank[i], NULL, EmployeeArrive, (void*) &var[i]);
                e++;
            }else{
                var[i].log = log;
                var[i].ID = h;
                pthread_create(&bank[i], NULL, HackerArrive, (void*) &var[i]);
                h++;
            }
        }
    }
    for (i=0; i<E+H; i++){
        pthread_join(bank[i], NULL);
        printf("join %i\n", i);
    }
    return 0;
}

运行：./work -h 4 -e 0 -b 1

他们运行：./work -h 5 -e 0 -b 1

如果他们将“-h”的值增加超过 4，则会收到分段错误

为什么这个？

4

2 回答 2

3

您的 s 数组的分配pthread_t不太正确。您想为pthread_t实例数组分配存储空间，但目前只为指针分配空间。

通过不为正确的类型分配空间，当您稍后写入此数组时，您可能会写入超出分配内存的末尾。这会产生不确定的后果；在这种情况下，您可能会覆盖程序其他部分使用的内存。这很可能会导致段错误。

您应该按如下方式更改分配

pthread_t* bank = malloc((E+H) * sizeof(*bank));

同样的问题适用于应该像这样分配的param数组var

param* var = malloc((E+H) + sizeof(*var));

请注意，free稍后在您的程序中使用这些数组对您来说是个好习惯

for (i=0; i<E+H; i++){
    pthread_join(bank[i], NULL);
    printf("join %i\n", i);
}
free(bank);
free(var);
于 2013-10-25T16:00:37.617 回答
2

请更仔细地阅读您的代码。这个：

param* var = malloc((E+H) + sizeof(*var));

应该是这样的：

param* var = malloc((E+H) * sizeof(*var));
//                        ^

在此更改后，您的代码对我有效（或至少不会崩溃）：

paul@local:~/src/c/scratch$ ./thread -h 2 -e 2 -b 2
Create Employee 0
Create Hacker 1
Create Employee 1
Create Hacker 0
join 0
join 1
join 2
join 3
paul@local:~/src/c/scratch$

使用像 valgrind 这样的工具可以帮助您在几分钟内找到它。

正如我在另一条评论中提到的，您应该在每次调用函数时检查返回malloc()，fopen()否则您完全不知道您是否忽略了您的函数试图告诉您的重要错误。pthread_create()pthread_join()

于 2013-10-26T02:35:58.337 回答