Поделиться именованными семафорами POSIX - PullRequest
0 голосов
/ 05 июня 2018

У меня проблемы с пониманием того, как разделить семафор POSIX между несколькими процессами.Я пытаюсь сделать следующее:
1. Производитель инициализирует семафор
2. Производитель отправляет 10 токенов на семафор и спит 1 секунду, прежде чем сделать это
3. Потребитель получает токен отсемафор
Когда я запускаю моего производителя, возникает ошибка сегментации (дамп памяти).Кроме того, я не уверен, что мой способ совместного использования именованного семафора правильный.
Производитель:

#include <semaphore.h>
#include <stdio.h>
#include <errno.h>
#include <stdlib.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <sys/mman.h>

#define SEM_NAME "/mutex"

int main () {
    sem_t* sem = sem_open(SEM_NAME,O_CREAT,0644,0);
    for (int i = 0; i<10; i++) {
        sleep(1);
        sem_post(sem);
        printf("Token was posted! \n");
    }   
    sem_close(sem);
    sem_unlink(SEM_NAME);
}

Потребитель:

#include <pthread.h>
#include <stdlib.h>
#include <stdio.h>
#include <semaphore.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/syscall.h>
#include <fcntl.h>    

int main () {
    sem_t *mutex = sem_open("/mutex",O_CREAT);
    for(int i = 0; i<10; i++) {
        sem_wait(mutex);
        printf("One Token was consumed! %d",(int) getpid());
    }
    sem_close(mutex);
}

1 Ответ

0 голосов
/ 05 июня 2018

Заставьте потребителя подождать:

sem_wait(mutex);

и очистить каждый отпечаток (если не все отпечатки могут быть сброшены в конце):

print("One token consumed\n");

Также;пожалуйста, позаботьтесь о возвращенном значении от open:

if (mutex==SEM_FAILED) exit(1);

и

if (sem==SEM_FAILED) exit(1);
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...