共享名为 POSIX 的信号量
Share named POSIX semaphores
我无法理解如何在多个进程之间共享 POSIX 信号量。我正在尝试执行以下操作:
1.生产者初始化一个信号量
2. 生产者向信号量发送 10 个令牌并在发送前休眠 1 秒
3.消费者从信号量
中获取一个token
当我启动我的生产者时,发生分段错误(核心转储)。此外,我不确定我共享命名信号量的方式是否正确。
制作人:
#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);
}
让您的消费者等待:
sem_wait(mutex);
并刷新每个打印(如果不是打印可能会在最后全部刷新):
print("One token consumed\n");
还有;请注意打开的返回值:
if (mutex==SEM_FAILED) exit(1);
和
if (sem==SEM_FAILED) exit(1);
我无法理解如何在多个进程之间共享 POSIX 信号量。我正在尝试执行以下操作:
1.生产者初始化一个信号量
2. 生产者向信号量发送 10 个令牌并在发送前休眠 1 秒
3.消费者从信号量
中获取一个token
当我启动我的生产者时,发生分段错误(核心转储)。此外,我不确定我共享命名信号量的方式是否正确。
制作人:
#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);
}
让您的消费者等待:
sem_wait(mutex);
并刷新每个打印(如果不是打印可能会在最后全部刷新):
print("One token consumed\n");
还有;请注意打开的返回值:
if (mutex==SEM_FAILED) exit(1);
和
if (sem==SEM_FAILED) exit(1);