每个实例都有生产者和消费者。每个实例通过生产者API发送消息请求数据，其他实例通过消费者API接收消息。现在，因为只有一个topic在交换数据，并且每个实例都是同一topic的生产者和消费者，所以相同的实例会获得自创建的消息。这是一种预期的行为。我的问题是:忽略给定应用程序实例上的自创建消息的有效方法是什么？
我正在使用linux box上的c++ library library库。
浏览 0提问于2018-02-07得票数 0
在我们的Linux系统上，我们使用命名管道进行进程间通信(生产者和消费者)。
为了测试消费者(Java)代码，我想(用Java)实现一个虚拟生产者，它向连接到消费者的命名管道写入数据。在Linux中我可以使用mkfifo (称为使用Runtime.exec() )，但在Windows上该如何操作呢？
浏览 2提问于2009-03-11得票数 28
回答已采纳
1回答
两个进程写入共享内存
、、、
我必须解决C，Linux中的两个生产者和一个消费者的问题，即信号量和共享内存。我有三个进程:第一个进程是生产者，第二个进程是生产者，第三个进程是消费者。生产者从自己的文件中读取并将其写入到一个缓冲区中。使用者必须从缓冲区读取并写入标准输出。 }
fclose (fp); /
浏览 0提问于2014-06-22得票数 0
1回答
我一直在研究linux中的共享内存。c++中有1个生产者进程和3个消费者进程。生产者进程通过'shm_open()‘调用创建共享内存。我们如何知道进程仍在从共享内存中读取数据？
浏览 2提问于2020-09-11得票数 0
2回答
我之所以要求这样做，是因为我有很多线程，比如10，充当使用者，和2个生产者，每个使用者线程都有自己的链接列表(缓冲器)，生产者会根据特定的规则将数据发送到这些线程中的一个，所以有时候生产者1发送给消费者1，然后再发送给消费者2，然后返回到消费者1等等。所以我在想这个，
生产者1调用函数链接-列表来共享数据(IPC)并将lock5传递给这个函数，在这种情况下，它将是锁5。当使用者5调用函数链接列表时，它
浏览 1提问于2012-12-25得票数 0
我正在研究一个无限消费者的生产者-消费者问题。生产者可以根据需要将任意多个任务放入处理队列。当队列为空时，使用者将阻塞线程。return } print(error)}
通常我会将循环中的所有内容放在一个自动释放池中，然而，这在Linux
浏览 13提问于2017-08-11得票数 8
1回答
线程多线程
、、、、
这是一个设计问题。2生产者生成" entry“(它是无符号int)，并排队到Queue12半消费者，从queue1排出条目，并从queue2 排到queue22消费者。
参赛总人数为500人。我的问题是:当所有500个条目都通过queue1路由到队列2并退出队列时，我如何才能让这两个半消费者和消费者存活呢？对于生产者线程来说，这很容易，因为我可以维护条目的全局计数。环境: Linu
浏览 1提问于2011-02-07得票数 2
1回答
我有一个生产者进程，它写入一个mmap文件，而一个消费者进程则从中读取。这是在Linux上。
如果生产者对mmap进行了更改，但没有立即刷新，那么当消费者访问它时会发生什么？
浏览 4提问于2011-04-13得票数 2
回答已采纳
2回答
执行者框架-生产者消费模式
、、、、
许多生产者-消费者设计可以用Executor任务执行框架来表示，本身就是使用生产者-消费者模式。如果是的话，生产者-消费者模式对框架的实现有什么帮助？
浏览 1提问于2017-10-24得票数 1
回答已采纳
考虑生产者-消费者问题，有一个生产者和几个消费者。消费者等待，直到他们被告知已经产生了价值。生产者写入一个值并通知所有消费者，然后消费者读取该值。最后:使用屏障同步消费者和生产者的终止。问:我是否应该为消费者提供读取值的独占访问权限(例如，同步)(或者为生产者提供写操作？)我知道最明显的答案是：“真的吗?不！”但我只想确定我没有遗漏任何奇怪的细节。
浏览 2提问于2013-04-20得票数 0
1回答
Unix用户空间中的实时IPC
、、、、
我想为以下问题寻求最佳方法:我有两个截然不同的过程:生产者和消费者。生产者产生项目，其中每个项目都是一个无符号整数。而消费者对它们的消费，与普通消费者生产者的问题不同的是，消费者需要知道物品生产的确切时间。消费者不能信任生产者，所以生产者不应该将时间与商品一起提供，这迫使消费者在消费商品的那一刻向系统询问当前时间。由于生产者是一个实时应用程序，所
浏览 0提问于2017-05-31得票数 2
6回答
介绍了用Java实现著名的“生产者-消费者”问题。
它使用wait()和notifyAll()来确保生产者线程和消费者线程之间的正确通信。这位导师故意创建了几个生产者线程，而只有一个消费者线程，但他留下了一个未回答的问题：“最好是生产者线程和消费者线程的数量相等，如果生产者线程比消费者线程多，就会有问题”。然而，他没有具体说明问题是什么。我个人认
浏览 2提问于2013-04-05得票数 5
回答已采纳
我在windows机器上运行zookeeper，kafka服务器和一个消费者客户端。当我在另一台同样运行windows的机器上使用python或c++编写的简单生产者程序时，一切都正常工作。然而，当我在linux机器上使用相同的生产者程序时，它不能工作，它指责无法解决。所有计算机都连接在同一网络上。运行windows且带有服务器和消费者的计算机： IP:192.168.0.149
hostname:something 第二台运行linux或windows的机器(双引导)，带有生产
浏览 17提问于2020-01-05得票数 1
我需要实现多个生产者和一个消费者的问题。限制是我有两个生产者和一个消费者。消费者应该仅在收到来自两个生产者的通知时才开始处理。在此之前，消费者不应该做任何事情。但每个生产者都是独立工作的，他们可以继续生产。你能帮我做这件事吗？HSK
浏览 5提问于2012-11-21得票数 2
回答已采纳
我想使用ThreadPool为消费者实现一个生产者-消费者模式。我将有一个请求的生产者和多个消费者来处理传入的请求。当使用线程池实现消费者时，我的问题是，我是否应该仍然有自己的队列供生产者放置请求，然后将它们传递给消费者threadpool，或者我是否应该让生产者直接将其传递到ThreadPool队列？我对最后一个问题的担忧是，一个人可以向ThreadPool队列传递多少任务，以及以什么速率传递？<
浏览 6提问于2010-10-04得票数 1
回答已采纳
我是oracle Webcenter portlets的新手：
生产者如何与消费者沟通，刷新或推送内容？通过在javascript(Jquery)中设置时间间隔并向生产者发出ajax请求，我能够刷新使用者(消费
浏览 2提问于2013-03-20得票数 2
1回答
在Andrew Tanenbaum的关于操作系统的书中，在关于消费者/生产者问题一节中，他给出了一个关于系统的例子，该系统由一个生产者和一个消费者组成，生产者将数据块插入缓冲区，消费者将数据块从缓冲区中取出当消费者验证计数器为零时，它将休眠。当生产者验证计数器为零，并将一些数据放入缓冲区时，它会向消费者发送唤醒信号。如果消费者在仍然唤醒时接收到唤醒信号，则唤醒等待位被设置为1。在睡眠之前，
浏览 26提问于2019-01-07得票数 0
有一个生产者和n个消费者。生产者将n个作业分配给n个消费者，并调用pthread_cond_wait() n次以等待消费者完成所分配的作业。在使用作业之后，每个消费者都会调用pthread_cond_signal()来通知生产者。我的问题是“消费者对pthread_cond_signal()的n次调用会使生产者从pthread_cond_wait()中出来n次吗?
浏览 0提问于2013-03-20得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM活动推荐
腾讯云开发者
