在我们的Linux系统上，我们使用命名管道进行进程间通信(生产者和消费者)。
为了测试消费者(Java)代码，我想(用Java)实现一个虚拟生产者，它向连接到消费者的命名管道写入数据。在Linux中我可以使用mkfifo (称为使用Runtime.exec() )，但在Windows上该如何操作呢？
浏览 2提问于2009-03-11得票数 28
回答已采纳
1回答
我一直在研究linux中的共享内存。c++中有1个生产者进程和3个消费者进程。生产者进程通过'shm_open()‘调用创建共享内存。我们如何知道进程仍在从共享内存中读取数据？
浏览 2提问于2020-09-11得票数 0
每个实例都有生产者和消费者。每个实例通过生产者API发送消息请求数据，其他实例通过消费者API接收消息。现在，因为只有一个topic在交换数据，并且每个实例都是同一topic的生产者和消费者，所以相同的实例会获得自创建的消息。这是一种预期的行为。我正在使用linux box上的c++ library library库。
浏览 0提问于2018-02-07得票数 0
我在windows机器上运行zookeeper，kafka服务器和一个消费者客户端。当我在另一台同样运行windows的机器上使用python或c++编写的简单生产者程序时，一切都正常工作。然而，当我在linux机器上使用相同的生产者程序时，它不能工作，它指责无法解决。所有计算机都连接在同一网络上。我尝试用几种不同的方式在kafka server.properties中设置listeners和advertised.listeners，但效果相同。运行windows且带有服务器和<
浏览 17提问于2020-01-05得票数 1
1回答
两个进程写入共享内存
、、、
我必须解决C，Linux中的两个生产者和一个消费者的问题，即信号量和共享内存。我有三个进程:第一个进程是生产者，第二个进程是生产者，第三个进程是消费者。生产者从自己的文件中读取并将其写入到一个缓冲区中。使用者必须从缓冲区读取并写入标准输出。 }
fclose (fp); /
浏览 0提问于2014-06-22得票数 0
1回答
有一个程序是使用生产者和消费者模式实现的。生产者根据查询列表从数据库中获取数据，并将其放入数组阻塞队列中...消费者根据数组阻塞队列中的数据编制excel报表。为了提高性能，我希望拥有动态数量的生产者和消费者。例如，当生产者速度慢时，拥有更多的生产者..当消费者慢的时候，有更多的消费者。我怎样才能拥有动态的生产者和消费者？
浏览 0提问于2018-07-29得票数 0
2回答
我之所以要求这样做，是因为我有很多线程，比如10，充当使用者，和2个生产者，每个使用者线程都有自己的链接列表(缓冲器)，生产者会根据特定的规则将数据发送到这些线程中的一个，所以有时候生产者1发送给消费者1，然后再发送给消费者2，然后返回到消费者1等等。所以我在想这个，
生产者1调用函数链接-列表来共享数据(IPC)并将lock5传递给这个函数，在这种情况下，它将是锁5。当使用者5调用
浏览 1提问于2012-12-25得票数 0
考虑生产者-消费者问题，有一个生产者和几个消费者。消费者等待，直到他们被告知已经产生了价值。生产者写入一个值并通知所有消费者，然后消费者读取该值。最后:使用屏障同步消费者和生产者的终止。问:我是否应该为消费者提供读取值的独占访问权限(例如，同步)(或者为生产者提供写操作？)我知道最明显的答案是：“真的吗?不！”但我只想确定我没有遗漏任何奇怪的细节
浏览 2提问于2013-04-20得票数 0
1回答
我有一个生产者进程，它写入一个mmap文件，而一个消费者进程则从中读取。这是在Linux上。
如果生产者对mmap进行了更改，但没有立即刷新，那么当消费者访问它时会发生什么？
浏览 4提问于2011-04-13得票数 2
回答已采纳
1回答
线程多线程
、、、、
我总共有6个线程和两个FIFO队列。这6个线程是：参赛总人数为500人。我的问题是:当所有500个条目都通过queue1路由到队列2并退出队列时，我如何才能让这两个半消费者和消费者存活呢？对于生产者线程来说，这很容易，因为我可以维护条目的全局计数。环境: Linux，线程，
浏览 1提问于2011-02-07得票数 2
我想实现一个生产者/消费者场景，其中我有多个生产者和一个消费者。生产者不断地将项目添加到队列中，而消费者则将这些项目出队。当消费者已经处理了足够的项目时，生产者和消费者都应该停止执行。当消费者处理足够多的项目时，它可以很容易地终止自己。但制片人也应该知道什么时候退出。典型的生产者毒丸在这里不起作用。
一种方法是在消费者和</em
浏览 5提问于2013-06-18得票数 0
1回答
我想在两个pthread之间实现一个无锁的单生产者、单消费者循环队列；用C语言，在ARM Linux上。
队列将保存字节，生产者将memcpy()内容放入，消费者将它们写出到文件中。认为我可以在int中存储头部和尾部偏移量，然后一切都会正常工作，这是不是很天真？我想知道编译器优化意味着我的头/尾写位于寄存器中，对其他线程不可见，或者需要在某个地方设置内存屏障。
浏览 48提问于2011-06-23得票数 1
回答已采纳
我有一些程序产生数据和其他程序消耗数据。这些程序是用c++ (11)编写的。我想启动一些生产者和一些消费者的计划。最后，我需要控制程序运行在哪个核心上。如何控制程序分发的方式？编辑:也许我应该加上服务器正在运行Linux。Linux的解决方案将是很棒的，但同时支持Linux和
浏览 7提问于2015-04-09得票数 1
回答已采纳
1回答
Unix用户空间中的实时IPC
、、、、
我想为以下问题寻求最佳方法:我有两个截然不同的过程:生产者和消费者。生产者产生项目，其中每个项目都是一个无符号整数。而消费者对它们的消费，与普通消费者生产者的问题不同的是，消费者需要知道物品生产的确切时间。消费者不能信任生产者，所以生产者不应该将时间与商品一起提供，这迫使消费者在消费商品的那一刻向系统询问当前时间。由于生产者是一个实时应用程序，所有这些都需要在对<
浏览 0提问于2017-05-31得票数 2
在Flex中NetConnection和消费者/生产者有什么区别？他们似乎都使用RTMP，但是消费者/生产者使用通道，而NetConnection不使用。消费者/生产者是否在底层使用NetConnection？
浏览 1提问于2009-10-21得票数 0
回答已采纳
我需要实现多个生产者和一个消费者的问题。限制是我有两个生产者和一个消费者。消费者应该仅在收到来自两个生产者的通知时才开始处理。在此之前，消费者不应该做任何事情。但每个生产者都是独立工作的，他们可以继续生产。你能帮我做这件事吗？HSK
浏览 5提问于2012-11-21得票数 2
回答已采纳
3回答
我有一个应用生产者-消费者设计模式的应用程序。它是用java编写的。简而言之，生产者将项目放在阻塞队列中，消费者从那里取出项目。消费者应该一直运行，直到生产者发出停止的信号。将这个信号从生产者传递给消费者的最好的方式是什么？首席设计师说他希望保持生产者和消费者的分离，但除了在消费者线程池上调用一个方法之外，我没有看到其他任何方法。
浏览 4提问于2013-05-13得票数 1
回答已采纳
我们在课堂上学习了生产者/消费者模式，但仅以一个生产者和一个消费者为例。在我们的家庭作业中，我们被要求做以下工作：
在这种情况下，有人能向我解释实行多生产者和多消费者而不是单一生产者和<e
浏览 0提问于2020-04-18得票数 0
回答已采纳
1回答
我正在尝试写一个生产者消费者代码。下面是我编写的原始代码。编辑
根据建议，我尝试更改代码，以便有两个独立的对象供生产者和使用者锁定。此外，当一个对象被放入缓冲区时，生产者会通知消费者。
浏览 1提问于2018-12-21得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
