Ошибка сегмента в программе потребителя производителя - PullRequest
0 голосов
/ 09 марта 2020

Я изучал параллельное программирование, внедряя проблему потребителя производителя. У кода только один производитель и один потребитель. Поток потребителя некоторое время блокируется на пустой семафор. Код генерирует segfault 11, который я не умею отлаживать. Я попытался удалить while l oop в потоке потребителя, после чего я не вижу segfault, почему это так?

#include <iostream>
#include <cstdlib>
#include <pthread.h>
#include <queue>
#include <unistd.h>
#include <semaphore.h>
using namespace std;

queue<int> buff;
pthread_mutex_t mut = PTHREAD_MUTEX_INITIALIZER;
sem_t empty;

void producer(int i){

   pthread_mutex_lock(&mut);
   buff.push(i);
   sem_post(&empty);
   pthread_mutex_unlock(&mut);

}

void* produce_data(void* arg){
    for(int i = 5 ; i < 10 ; i++){
        producer(i);
    }

   return NULL;
}

void* consumer(void* arg){

    while(1){
        sem_wait(&empty);
        pthread_mutex_lock(&mut);
        int temp = buff.front();
        cout << temp <<" " ;
        buff.pop();
        pthread_mutex_unlock(&mut);
     }

    return 0;
}

int main () {
   pthread_t prod;
   sem_init(&empty, 0, 0);
   pthread_create(&prod, NULL, produce_data , NULL);

   pthread_t consum2;

   pthread_create(&consum2, NULL,consumer , NULL);

   pthread_join(prod,NULL);

   pthread_join(consum2,NULL);


   return 0;

}

1 Ответ

0 голосов
/ 09 марта 2020

Sem_init () устарела в macos. Компиляция вашей программы должна была показать это. Кроме того, если вы проверили возвращаемые значения, вы бы знали, что sem_init (), sem_post (), sem_wait () не работают. По какой-то причине из вашей очереди выскакивает где-то 1023, и это SEGV.

...