我正在尝试用一个自定义的队列来代替一些线程通信，生产者使用的是PostThreadMessage，消费者使用的是WaitForSingleObject/PeekMessage。我需要的是，但boost和C++都不是我的选择。
不想重新实现轮子，有人用C语言实现了这样的队列吗？
浏览 2提问于2010-01-27得票数 4
3回答
我想知道如何在像Haskell这样的函数式编程语言中实现生产者/消费者？它与命令式语言有什么不同？我对函数式编程语言的理解很原始。任何帮助都将不胜感激。
浏览 0提问于2009-08-12得票数 8
1回答
我想在两个pthread之间实现一个无锁的单生产者、单消费者循环队列；用C语言，在ARM Linux上。
队列将保存字节，生产者将memcpy()内容放入，消费者将它们写出到文件中。
浏览 48提问于2011-06-23得票数 1
回答已采纳
1回答
我遇到了一个与Kafka消费者合作的特殊问题。当我有一个包含多个分区的主题和一个消费者组时，如果消费者数量小于分区数量，消费最终会变得不平衡。例如，如果我有8个分区和4个消费者，我会看到如下所示：C1 P0 1000000C2P2 0C3 P4
浏览 5提问于2020-05-12得票数 2
我在该应用程序中有两个线程，类似于生产者和消费者，其中一个线程不断地从第三方API (套接字连接)读取数据，并将其更新到缓存中。另一个线程(使用者)不断尝试从缓存中读取数据。
浏览 2提问于2012-09-17得票数 0
回答已采纳
我计划在我的干扰器中有许多类似的消费者。 #1 - type A, #2 - type B, #3 - type C, #4 - type A, #5 - type C, #6 - type C,(and so on)重要事项:我希
浏览 3提问于2017-04-12得票数 3
回答已采纳
我想使用ActiveMQ作为消息代理，在两个进程中的C++组件和Java组件之间进行通信。例如：C++组件是发布者，Java组件是订阅者(可能有多个订阅者)。然而，网站上的所有示例对于生产者和消费者都使用相同的语言。1. ActiveMQ可以在不同语言中为生产者/消费者工作吗？
2.在不同的进程中？多么?
浏览 0提问于2010-01-23得票数 2
回答已采纳
有一个名为GAsyncQueue的数据结构，它允许线程间的通信，而不需要信号量/锁等，甚至可以使实现生产者/消费者解决方案的任务变得微不足道。如果两个不同的线程将数据推送到GAsyncQueue结构，push函数将在内部实现对队列的互斥访问；更神奇的是，如果一个线程调用pop函数，但其中没有数据，则调用线程将阻塞，直到其他线程将一些数据推送到队列中尽管我非常喜欢它，但这个库是为C语言构建的，并且可能有更好的高级语言替代方案。我正在考虑使用glib，但在C</e
浏览 0提问于2013-02-28得票数 4
回答已采纳
我已经找到了很多这样的C#示例，但我需要在powershell中使用它。有人能帮我把这个翻译成powershell吗？要转换的C#代码： public object ConvertTo(object obj, Type
浏览 2提问于2013-01-11得票数 1
回答已采纳
2回答
如何在C中实现我自己的信号量？
、、、、
我正致力于通过不同的方法解决生产者/消费者的问题。我目前正在处理的问题涉及到我自己实现的信号量，加上Peterson的解决方案，以保护信号量的down()和up()函数调用。问题是，我正在使用C语言，创建信号量的唯一方法是使用带有函数指针的struct来表示down()和up()。这主意对吗？
浏览 3提问于2014-02-27得票数 0
回答已采纳
以下maven对Kafka 0.9客户端API的依赖有什么不同？<dependency> <artifactId>kafka_2.10</artifactId> <exclusions> <groupId>log4j</groupId&g
浏览 1提问于2016-02-01得票数 9
我已经在本地机器上设置了apache kafka，并且工作正常，当我将一条消息发布到生产者中时，它立即在消费者提示中流动。
可以从我的本地文件夹配置连续文件流吗？我该怎么做呢？
浏览 0提问于2016-07-28得票数 0
我计划实现消息总线，其中消息将在.Net核心应用程序中生成，但消费者应用程序将在安卓设备上运行，并使用Java语言编写。在最初的近似中，发布者应用程序将对消费者一无所知。我很好奇，有没有办法或变通办法在Java上实现MassTransit消费者应用程序？我用谷歌搜索了大约2个小时，没有找到任何信息，但我认为我的搜索请求是不正确的。
浏览 16提问于2021-11-22得票数 0
1回答
单生产者多消费者Java
、、、、
我是Java并发的新手，正在尝试实现/实现单个ProducerP1和多个消费者C1、C2、C3。 这个想法是生产者P1放入值，消费者C1，C2，C3都运行他们的任务来单独读取P1放入的值。一旦C1、C2、C3读取值，P1就会再次放入一个新数据。然后C1、C2、C3读取数据，这个循环就会继续。等待通知适
浏览 16提问于2018-12-27得票数 2
回答已采纳
1回答
我想实现一个JMS队列，以确保每个消息只传递给一个使用者。将会有许多不同类型的消费者在监听队列。我的问题是，如何确保当消费者作为消费者注册到队列时，他们实现了选择器，以避免以下情况。如果我有3个消息类型(A，B和C)和3个消费者(a，b和c)，每个消费者只消费一个消息类型，如下所示: a->A b->B c->C，则所有类型A的消息将发送到1，所有类型B的消息将发送到2，依此类推。
浏览 2提问于2011-09-20得票数 2
回答已采纳
3回答
假设有1个生产者P和2个消费者C1和C2。并且有2个队列Q1和Q2，它们都具有特定的容量。
P将生成项目，并将其交替放入Q1和Q2中。商品是为特定消费者生产的，不能被其他消费者消费。如何在java语言中实现以下功能:在启动3个线程后，如果Q1为空，线程C1将被阻塞，直到Q1中出现异常时才会通知它。Q2也是如此。当Q1和Q2都已满时，P将被阻塞，直到当Q1或Q2未满时被通知。我在考虑使用BlockingQueue，当消费者的队列为空时，
浏览 3提问于2013-05-31得票数 8
我有两个线程生产者和消费者。在objective语言中，我使用了信号量来阻止和释放线程使用者。 dispatch_semaphore_signal(semaPhoreBlock);
}
浏览 4提问于2017-06-22得票数 0
2回答
我正在构建一个排队系统，它通过在mongodb中使用capped_collections和可裁剪游标实现的堆栈将消息从一个进程传递到另一个进程。我的问题是，如果我实现了多个接收进程，有没有一种方法可以保证一个新的文档只会被其中一个进程使用可拖尾的游标读取一次？这样做的目的是避免在有两个接收进程在队列中查找新消息时执行两次操作。
浏览 0提问于2011-09-25得票数 5
回答已采纳
这样做的目的是，如果生产者的运行速度比消费者的速度快，那么列表就不会无限增长。请注意，不起作用，因为(1)代码立即返回，这根本不是阻塞。有没有办法用Lua实现BLPUSH，或者一定要用C语言？
浏览 0提问于2017-11-07得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
