Мы имитируем ресторан-буфет с тандури-цыпленком с одним шеф-поваром и несколькими гостями, который похож на проблему с одним производителем/несколькими потребителями. Мы реализуем одну программу с несколькими потоками, каждая из которых содержит шеф-повара или гостя. Мы также применяем один инструмент синхронизации - семафоры, который может решить проблему для , синхронизируя общие ресурсы с несколькими потоками. В этом проекте мы узнаем, как создать многопоточный процесс и как синхронизировать потоки с помощью семафоров.Ошибка сегментации в приведенном ниже коде c, составленном в Linux
#include <stdlib.h>
#include <stdio.h>
#include <pthread.h>
#include <semaphore.h>
struct threadInfo
{
int id;
};
/* input variables */
int nofCustomers=4,item,nofChicken=3;
pthread_attr_t attr; /*Set of thread attributes*/
pthread_t chef_t,customer_t[100];
/* the semaphores */
sem_t full, empty;
void *chef(void *param); /* the producer thread */
void *customer(void *param); /* the consumer thread */
void initializeData()
{
/* Create the full semaphore and initialize to 0 */
sem_init(&full, 0, 0);
/* Create the empty semaphore and initialize to BUFFER_SIZE */
sem_init(&empty, 0, nofChicken);
/* Get the default attributes */
pthread_attr_init(&attr);
}
ПРОДЮСЕР
/* Producer Thread */
void *chef(void *param)
{
printf("Chef Starts Cooking\n");
while(1)
{
/* acquire the empty lock */
sem_wait(&empty);
if(insert_item())
{
fprintf(stderr, " Producer report error condition\n");
}
/* signal full */
sem_post(&full);
sleep(1);
}
}
ПОТРЕБИТЕЛЕМ
/* Consumer Thread */
void *customer(void *param)
{
int toeat=1+rand()%4,ate=0,t=nofCustomers;
int *id=(int*)param;
printf("Guest %d arrives and wants to eat %d food\n", id, toeat);
while(1)
{
/* aquire the full lock */
sem_wait(&full);
if(remove_item())
{
fprintf(stderr, "Consumer report error condition\n");
}
else
{
ate++;
printf("Guest %d eats a tandoori chicken[%d/%d]\n", id,ate,toeat);
}
if(ate==toeat)
{
nofCustomers--;
printf("Guest %d finishes and exits\n",id);
}
if(nofCustomers==0)
{
printf("All guests finish eating and exit\n");
break ;
}
/* signal empty */
sem_post(&empty);
sleep(toeat);
}
}
ИНК в критической секции
/* Cook food */
int insert_item()
{
/* When the item is not full,cook food
increment the item*/
if(item <= nofChicken)
{
item++;
printf("Chef cooks one tandoori chicken.[%d/%d]\n",item,nofChicken);
return 0;
}
else
{ /* Error the items are full */
return -1;
}
}
В декабре критической секции
/* Eat food */
int remove_item() {
/* When the items is/are cooked, eat the item
i.e.., decrement the item */
if(item > 0)
{
item--;
return 0;
}
else { /* Error no items */
return -1;
}
}
Основная функция
int main()
{
/* Loop counter */
int i;
struct threadInfo *info;
//input (Havent written code for input includes nofChicken andnofCustomers
/* Initialize the app */
initializeData();
/* Create the producer thread */
pthread_create(&chef_t,&attr,chef,NULL);
/* Create the consumer threads */
for(i = 1; i <= nofCustomers; i++)
{
info->id=i;
pthread_create(&customer_t[i],&attr,customer,(void *)info);
}
return 0;
}
вина Сегментация в Бове КОД
Можете ли вы попробовать запустить код в GDB, чтобы найти, где именно происходит segfault? – Matt
Используйте gdb как рекомендуется для поиска точной линии разлома seg. Но для начинающих: 'info-> id = i;' может вызвать ошибку seg, потому что 'info' является неинициализированным указателем. Другие ошибки включают передачу одного и того же указателя 'info' ко всем потокам, что означает, что каждый поток будет видеть случайное значение' info-> id', а также 'main' не дожидается завершения потоков (' pthread_join') перед выходом. – kaylum
Добро пожаловать в переполнение стека! Чтобы помочь людям ответить на ваш вопрос, вам нужно быть более конкретным в отношении ошибки. Пожалуйста, отредактируйте свое сообщение, чтобы включить точную трассировку стека, которую вы получаете от запуска вашего [mcve] (желательно с помощью copy + paste, чтобы избежать ошибок транскрипции). –