回答情况：
提问时间：
问题标签：
我在生产者-消费者模式中有两个线程。当消费者收到数据时，它会调用一个耗时的函数expensive()，然后进入for循环。但是，如果消费者正在工作时有新数据到达，它应该中止当前工作(退出循环)，并从新数据开始。if not q.empty():
break 但此代码的问题是，如果生产者将数据放得太快，并且队列中有许多项，消费者将执行expensive(d)调用加上一个循环迭代，然后对每个项进行中止，这是非常耗时的。
浏览 33提问于2021-04-09得票数 2
在我的场景中，我有一个boroker，一个生产者，一个消费者。我使用activemq来编写我的应用程序。logs to db.As你知道将日志写入db是一个耗时的过程，这就是为什么消费者比producer.For ex更慢的原因。I send 100.000 message (大型对象).Producer在20 mins.But内完成发送消息当生产者完成时，消费者已经完成了4.000消息的处理。我的问题是；有没有办法说procuder“如果代理中有x条消息等待消费，并尝试在一段时间后发送”？
怎样才能解决
浏览 0提问于2013-09-18得票数 0
1回答
(我正在编辑这个问题，因为我认为它不够清楚)
我如何加载测试我的卡夫卡消费者？我已经看过很多关于负载测试的文章，apache，但是没有关于负载测试的文章。为了前夫。我的卡夫卡弹簧引导消费者听这个主题，消费事件，并开始处理它。杰米只是向我展示了关于制片人的报道，仅此而已。有没有更好的方法来加载测试春季启动卡夫卡消费者应用程序并得到报告？从消耗时间到过程的结束？
浏览 0修改于2021-02-18得票数 1
有没有办法做到这一点:一个生产者总是向一个代理发送消息，而在另一边，有3个consumers.Each消费者监听代理，并可以从queue.Is获取任何消息。logs to db.As你知道将日志写入db是一个耗时的过程，这就是为什么消费者比producer.For ex更慢的原因。I send 100.000 message (大型对象).Producer在20 mins.But内完成发送消息当生产者完成时，消费者已经完成了4.000消息的处理。
浏览 4提问于2013-09-19得票数 0
1回答
从2010年到2014年，我有700个小时的汽油消耗时间序列。有一次，系列代表了一家公司的消费。一些人有恒定的消费，另一些人一年只消费4个月，还有一些人的消费波动性很高。我的目标是真正区分消费是恒定的群体和消费是可变的群体。然后，我想根据峰值的函数和它们消耗of的时间对变量消费者进行聚类。
浏览 2提问于2017-01-16得票数 0
5回答
我有一个生产者/消费者进程。消费的对象有一个ID属性(整型)，我希望一次只消费一个具有相同ID的对象。我该如何执行此操作？也许我可以做这样的事情，但我不喜欢这样(创建了太多的对象，而每天只能使用一两个具有相同ID的对象，并且锁(_lockers)有点耗时：
private readonly Dictionary<int
浏览 2修改于2012-12-08得票数 11
回答已采纳
我希望记录提供给_.flow的函数的每一次消耗时间。例如，对于以下代码， funcA,])funcA spent 1.21s.
funcB spent 0.45s
浏览 1提问于2019-07-23得票数 0
回答已采纳
3回答
当流的最后一个元素已经被处理并且流被完全“消费”时，有没有一种优雅的方法来注册回调？Stream<Row> rows = MyDB.query(sql).stream(); return rows;
} 现在，立即关闭连接是徒劳的，相反，当流被完全消耗时安排连接关闭将是很好的我知道有onClose()应用程序接口，但这依赖于消费者显式地在流上调用close()。
浏览 44修改于2019-06-13得票数 2
回答已采纳
问题如下：
假设我有一个中心任务生产者和一些客户端消费者。生产者生成任务，消费者接受任务(对于初学者，一次一个)，处理它们，当它们完成后，接受新的任务(我已经有一个任务队列)。问题是，如果考虑到任务从生产者到消费者的延迟，将任务分组在一起可能是有意义的。例如，假设我们总共有10个任务和2个消费者。如果每个任务的处理时间为5ms，网络延迟也为5ms，则向每个消费者发送两组各5个任务将花费5ms+ 5*5ms = 30ms，而单独发送任务将花费5*5ms + 5*5ms = 50ms，因为每个任务都会出现延迟
浏览 0提问于2011-11-09得票数 5
回答已采纳
3回答
queue.qsize())) save(queue.get())在这里，在我执行代码之后，队列仍然是空的。这里发生什么事情？
浏览 21修改于2021-09-17得票数 0
我正在使用rabbitmq topic exchange来消费从客户端推送的消息。因此，我创建了一个队列并将队列绑定到默认的exchange amq.topic。msg.fields.routingKey, msg.content.toString()); }, { noAck: true },); 但是，amqp每次连接并消费消息时当我有一个队列时，为什么要创建消耗时间中的临时队列？以及如何避免创建？ ?
浏览 30修改于2019-10-14得票数 0
当我检查循环的内存消耗时，我注意到在循环的每一次迭代中，消耗增加了1-2MB。tracemalloc.stop()
更新:我发现我可以通过在每次迭代结束时执行del rel、del some_other_attr_1、del some_other_attr_2来防止消费的增长
浏览 8修改于2022-06-08得票数 0
回答已采纳
接收方接收消息，然后执行一些非常耗时的任务(主要是针对非常大的数据量写入数据库)。由于接收方需要很长时间来完成任务，然后检索队列中的下一条消息，因此发送方将不断快速地填满队列。caseID"); dao.saveToDB(caseID);}
消费者收到的每条消息都包含一个由于生产者/消费者对caseID的发布/订阅使用相同的队列，因此目前只为RabbitMQ
浏览 0提问于2014-10-29得票数 21
我正在使用Kafka Streams创建一个基于Spring的服务，并注意到当我使用现有的@Bean KStream与为该流创建流时，会有很大的耗时差异。eventsKStream") KStream<String, String> eventsKStream) {}
我有一个消费者，正在使用控制台消费者...并注意到，对于第一种方法，数据需要几秒钟才能到达，但在第二种方法中，我会立即获得过滤后的数据！为什么第一种方法需要几秒钟时间才能将消息到
浏览 0修改于2019-12-01得票数 0
此外，标准中提供的惟一SQL Server操作是Execute查询，这是对消费的显著改进
到目前为止，我还没有找到任何方法来实现这种迁移，而不需要手动重新编码工作流既耗时又有风险，因此需要进行广泛的回归测试
浏览 1提问于2021-11-12得票数 0
回答已采纳
在amazon上使用这个应用程序，我希望能够按新创建的机器将同一组(演示-组)中的另一个使用者(使用者2)在同一个主题(演示-主题)中读取的方式来扩展它(当计算耗时很长时)，但以他们开始拆分负载的方式(消费者1需要一些负载，而消费者2接受其余的，但他们从来没有得到相同的消息)。在数据激增停止后，第二台机器被停用，消费者1再次承担所有负载。谢谢
浏览 2提问于2017-10-18得票数 0
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号