- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
不知道为什么消费者要完成所有工作?
我使用一个包含 10 个整数的数组为产品消费者创建一个信号量,该数组填充名称,并以 1 和 0(二进制)形式返回。即使生产者取消信号量,也会调用消费者。
为什么会出现这种情况?
这是代码:
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <sys/ipc.h>
#include <sys/shm.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <semaphore.h>
#include <fcntl.h>
#define SIZE 10
#define KEY 1234
int *Memory;
int i, j;
sem_t *sem;
char *name = "Hello";
int main(int argc, const char *argv[])
{
int shmid;
if ((shmid = shmget(KEY, sizeof(int) * SIZE, IPC_CREAT | S_IRWXU)) < 0)
{
perror("Error while creating shmget");
return 1;
}
pid_t pid;
sem = sem_open(name, O_CREAT, S_IRUSR | S_IWUSR, 1);
if ((pid = fork()) != 0)
{
if ((shmid = shmget(KEY, sizeof(int) * SIZE, S_IRWXU)) < 0)
{
perror("error in shmget");
return 1;
}
Memory = (int *)shmat(shmid, NULL, 0);
if (Memory == NULL)
{
perror("error in shmat");
return 1;
}
for (i = 0; i < 10; i++)
{
sem_wait(sem);
Memory[j] = i;
printf("Produced %i in box %i\n", i + 1, i + 1);
sem_post(sem);
sleep(1);
}
int status;
wait(&status);
sem_unlink(name);
sem_destroy(sem);
struct shmid_ds shmid_ds1;
if (shmctl(shmid, IPC_RMID, &shmid_ds1) < 0)
{
perror(
"Error in the father while executing shmctl when it was "
"elimnating the segment of shared memory");
}
}
else
{
if ((shmid = shmget(KEY, sizeof(int) * SIZE, S_IRWXU)) < 0)
{
perror("error in the producer with the shmget");
return 1;
}
Memory = (int *)shmat(shmid, NULL, 0);
if (Memory == NULL)
{
perror("error in the producer with the shmat");
return 1;
}
for (i = 0; i < 10; i++)
{
sem_wait(sem);
Memory[i] = -1;
printf("Consume and now it is %i in box %i\n", Memory[i], i + 1);
sem_post(sem);
}
}
return 0;
}
输出是:
Produced 1 in box 1
Consume and now it is -1 in box 1
Consume and now it is -1 in box 2
Consume and now it is -1 in box 3
Consume and now it is -1 in box 4
Consume and now it is -1 in box 5
Consume and now it is -1 in box 6
Consume and now it is -1 in box 7
Consume and now it is -1 in box 8
Consume and now it is -1 in box 9
Consume and now it is -1 in box 10
Produced 2 in box 2
Produced 3 in box 3
Produced 4 in box 4
Produced 5 in box 5
Produced 6 in box 6
Produced 7 in box 7
Produced 8 in box 8
Produced 9 in box 9
Produced 10 in box 10
最佳答案
#include <pthread.h>
#include <stdio.h>
#include <semaphore.h>
const int max = 5;
int arr[5], f = 0, r = -1;
sem_t s1, s2, sm;
void* eprod(void* pv)
{
int i, x;
printf("Producer Welcome\n");
// sleep(10);
while (1)
{
x = rand() % 100;
printf("producer going to add:%d\n", x);
sem_wait(&s2);
sem_wait(&sm);
// down s2 //buffer may be full
// lock sm
r = (r + 1) % max;
arr[r] = x;
sem_post(&sm);
sem_post(&s1);
sleep(10);
}
// unlock sm
// up s1
}
void* econs(void* pv)
{
int i, x;
printf("Consumer Welcome\n");
while (1)
{
sem_wait(&s1);
sem_wait(&sm);
// down s1
// lock sm
x = arr[f];
f = (f + 1) % max;
printf("Consumer removed element:%d\n", x);
sem_post(&sm);
sem_post(&s2);
// unlock sm
// up s2
// sleep(5);
}
}
int main()
{
pthread_t pt1, pt2;
sem_init(&s1, 0, 0); // 3rd Parameter ival=1
sem_init(&s2, 0, max); // 3rd Parameter ival=1
sem_init(&sm, 0, 1); // 3rd Parameter ival=1
pthread_create(&pt1, NULL, eprod, (void*)0);
pthread_create(&pt2, NULL, econs, (void*)1);
printf("Main Thread is Running\n");
pthread_join(pt1, NULL);
pthread_join(pt2, NULL);
printf("Main -- - - Thanks..!\n");
return 0;
}
希望这有帮助..
关于c - 具有信号量和 fork 的产品消费者,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/23485100/
有3个 repo : 有 OpenAI Baselines 存储库:https://github.com/openai/baselines . 我有它的 fork :https://github.co
我试图了解在调用 fork() 后复制文件描述符的含义及其对争用的可能影响。 在“Linux 编程接口(interface)”24.2.1 (p517) 中: When a fork() is per
我对 systemd 如何跟踪主进程存在后仍然存在的主进程的子进程感兴趣? 最佳答案 Systemd 为此使用了 cgroups。在启动任何使用服务文件定义的可执行文件之前,systemd 会创建一个
这是输出--- 家长:我的pid是4525 parent :我 parent 的 pid 是 3350 parent 开始- 4525 3350 fork 前 fork 前 child 4526 45
我之前 fork 了 jockm/vert.x 并向他发送了拉取请求。现在我想 fork vert-x/vert.x (jockm/vert.x 的上游)并向他们发送不同的拉取请求。但是,当我单击“F
我想控制从 Perl 脚本派生的进程的名称 a。理想情况下它会像这样: ./forker.pl | ... | | fork("forked.pl"); |\ | \ | `--------\ |
我知道 fork() 在更高级别上做什么。我想知道的是这个—— 一旦有 fork 调用,trap 指令就会跟随并且控制跳转以执行 fork “处理程序”。现在,这个创建子进程的处理程序如何通过创建另一
我正在研究操作系统测验,但我不知道输出什么 if(fork()) fork() 会产生。有人可以解释吗? 我不明白这一行: if(fork()) 编辑: 我所说的“输出”是指如果执行此代码,将
这个问题在这里已经有了答案: Why does this program print "forked!" 4 times? (6 个答案) 关闭 3 年前。 在 C 中,fork() 函数将为父进程
有什么方法可以区分程序中不同 fork() 函数创建的子进程。 global variable i; SIGCHLD handler function() { i--; } handle() {
我正在重新开发一个系统,该系统将通过 http 向多个供应商之一发送消息。原来是perl脚本,重新开发很可能也会用perl。 在旧系统中,同时运行多个 perl 脚本,每个供应商运行 5 个。当一条消
Git 的新手,仍然有点困惑。我在 github 上 fork 了一个项目,想将项目所有者最近对原始项目所做的一些更改引入/merge 到我的 fork 中。这可能吗?该项目是只读的,但基本上,我想让
根据维基百科(可能是错误的) When a fork() system call is issued, a copy of all the pages corresponding to the par
我需要帮助了解如何在 Go 中妖魔化进程。 package main import ( "fmt" "os" ) func start() { var procAttr os.Pro
我已经执行了这段代码。我知道消息的顺序是任意顺序的(因为我明确没有使用信号量)我的程序流程如何?为什么? 父级被执行,因此“baz”被打印一次。有人可以解释为什么不打印“bar”吗?为什么我得到“fo
这个问题已经有答案了: Why does this program print "forked!" 4 times? (6 个回答) 已关闭 5 年前。 我对 fork 进程有疑问。我有一个代码是 i
我在弄清楚如何使用在不同进程之间创建的列表时遇到了麻烦。我所拥有的是: FileList.h - 我创建的列表 #include "Node.h" typedef struct FileList {
好吧,所以我一直在 stackoverflow 上查找这个问题,并且肯定在谷歌上搜索了半个小时,但我得到的答案似乎与我真正想做的事情几乎没有任何关系,希望有人能提供帮助我在这方面,代码如下: int
我正在尝试了解 fork-join 的工作原理。 维基百科有以下合并排序示例,其中左半部分被 fork ,右半部分由当前线程处理。 mergesort(A, lo, hi): if lo t
下面的代码输出了一系列的过程,它到底做了什么: _PARENT_ / \ /
我是一名优秀的程序员,十分优秀!