【问题标题】:Share named POSIX semaphores共享命名的 POSIX 信号量
【发布时间】:2018-06-05 14:43:41
【问题描述】:

我无法理解如何在多个进程之间共享 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);
}

【问题讨论】:

    标签: c posix semaphore


    【解决方案1】:

    让您的消费者等待:

    sem_wait(mutex);
    

    并刷新每个打印件(如果不是打印件可能在最后全部刷新):

    print("One token consumed\n");
    

    还有;请注意打开的返回值:

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

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

    【讨论】:

    • 我忘记将 sem_post 更改为 sem_wait。但是为什么会出现分段错误呢?此外,我可以通过在一个外壳中执行生产者和在不同外壳中执行消费者来测试我的程序吗?
    • 看不到故障发生的原因。我测试的时候没有。是的,您需要同时启动两者(如果不是信号量,则不感兴趣)。
    • 重启后没有出现故障,谢谢!
    猜你喜欢
    • 2023-03-19
    • 1970-01-01
    • 2020-09-01
    • 2012-08-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多